1 files changed, 7 insertions, 1 deletions
diff --git a/src/DabMod.cpp b/src/DabMod.cpp
index 14c7c4b..7ee65dc 100644
--- a/src/DabMod.cpp
+++ b/src/DabMod.cpp
@@ -667,7 +667,13 @@ int main(int argc, char* argv[])
         ret = -1;
         goto END_MAIN;
 #else
-        inputZeroMQReader.Open(inputName.substr(4));
+        // The URL might start with zmq+tcp://
+        if (inputName.substr(0, 4) == "zmq+") {
+            inputZeroMQReader.Open(inputName.substr(4));
+        }
+        else {
+            inputZeroMQReader.Open(inputName);
+        }
         inputReader = &inputZeroMQReader;
 #endif
     }