diff --git a/sf-stream/src/main.cpp b/sf-stream/src/main.cpp index 796c2a5..367f875 100644 --- a/sf-stream/src/main.cpp +++ b/sf-stream/src/main.cpp @@ -38,7 +38,13 @@ int main (int argc, char *argv[]) auto ctx = zmq_ctx_new(); zmq_ctx_set (ctx, ZMQ_IO_THREADS, STREAM_ZMQ_IO_THREADS); - ZmqPulseReceiver receiver(config.n_modules, ctx, RECV_IPC_URL); + // TODO: This should be passed to the service and not calculated here. + vector ipc_urls; + for (int i=0; i