invert ZMQ input direction (encoders connect to mux)

2 files changed, 7 insertions, 2 deletions

diff --git a/doc/example.mux b/doc/example.mux
index 127d37a..868211d 100644
--- a/doc/example.mux
+++ b/doc/example.mux
@@ -86,7 +86,12 @@ subchannels {
     }
     rick {
         type dabplus
-        inputfile "rick.dabp"
+        ; example file input
+        ;inputfile "rick.dabp"
+        ; example zmq input:
+        ; accept connections to port 9000 from any interface
+        ; use fdk-aac-dabplus-zmq as encoder
+        inputfile "tcp://*:9000"
         nonblock false
         bitrate 96
         id 1
diff --git a/src/dabInputZmq.cpp b/src/dabInputZmq.cpp
index 13b812e..dd25806 100644
--- a/src/dabInputZmq.cpp
+++ b/src/dabInputZmq.cpp
@@ -97,7 +97,7 @@ int dabInputZmqOpen(void* args, const char* inputUri)
     dabInputZmqData* input = (dabInputZmqData*)args;
 
     std::string uri = "tcp://" + std::string(inputUri);
-    int connect_error = zmq_connect(input->zmq_sock, uri.c_str());
+    int connect_error = zmq_bind(input->zmq_sock, uri.c_str());
 
     if (connect_error < 0) {
         etiLog.print(TcpLog::ERR,  "Failed to connect socket to uri '%s': %s\n", uri.c_str(), zmq_strerror(errno));