From 87b708657a78cac4690ba81967e5ca03d7faab09 Mon Sep 17 00:00:00 2001
From: "Matthias P. Braendli" <matthias.braendli@mpb.li>
Date: Sun, 22 Feb 2015 21:39:56 +0100
Subject: Restart full modulator on ZeroMQ input overrun

---
 src/InputZeroMQReader.cpp | 9 ++++++++-
 1 file changed, 8 insertions(+), 1 deletion(-)

(limited to 'src/InputZeroMQReader.cpp')

diff --git a/src/InputZeroMQReader.cpp b/src/InputZeroMQReader.cpp
index 5fab447..7ac7d41 100644
--- a/src/InputZeroMQReader.cpp
+++ b/src/InputZeroMQReader.cpp
@@ -64,7 +64,14 @@ struct zmq_dab_message_t
 
 int InputZeroMQReader::Open(const std::string& uri, unsigned max_queued_frames)
 {
-    uri_ = uri;
+    // The URL might start with zmq+tcp://
+    if (uri.substr(0, 4) == "zmq+") {
+        uri_ = uri.substr(4);
+    }
+    else {
+        uri_ = uri;
+    }
+
     workerdata_.uri = uri;
     workerdata_.max_queued_frames = max_queued_frames;
     // launch receiver thread
-- 
cgit v1.2.3