implementation project(path: ':android:modules:tcp')
implementation project(path: ':android:modules:webrtc')
- implementation project(path: ':android:modules:ipc')
+// implementation project(path: ':android:modules:ipc')
implementation project(path: ':android:modules:rtsp')
implementation project(path: ':android:aitt-native')
import com.google.flatbuffers.FlexBuffersBuilder;
import com.samsung.android.aitt.Aitt;
import com.samsung.android.aitt.internal.Definitions;
-import com.samsung.android.modules.ipc.Ipc;
import java.nio.ByteBuffer;
private static final String TAG = "IpcHandler";
private Context context;
private String ip;
- private Ipc ipc;
private byte[] publishData;
public IpcHandler() {
public void subscribe(String topic, HandlerDataCallback handlerDataCallback) {
publishData = wrapPublishData(topic);
try {
- Ipc.ReceiveFrameCallback cb = handlerDataCallback::pushHandlerData;
- ipc = new Ipc(context, cb);
- ipc.initConsumer();
-
+ //TODO : Invoke IPC consumer/subscribe APIs
} catch (Exception e) {
Log.e(TAG, "Failed to subscribe to IPC");
}
@Override
public void publish(String topic, String ip, int port, byte[] message) {
- if (ipc == null)
- {
- ipc = new Ipc(context);
- ipc.initProducer();
- }
- ipc.writeToMemory(message);
+ //TODO: Invoke producer/publish APIs
}
@Override
public void unsubscribe() {
- if (ipc != null)
- ipc.close();
+ //TODO: Invoke IPC close APIs
}
@Override
include ':android:aitt-native'
include ':android:flatbuffers'
include ':android:mosquitto'
-include ':android:modules:ipc'
+//include ':android:modules:ipc'
include ':android:modules:rtsp'
include ':android:modules:tcp'
include ':android:modules:webrtc'