format of subscriptions changed (no * needed anymore)

1 files changed, 5 insertions, 2 deletions

diff --git a/src/zmq_engine.cpp b/src/zmq_engine.cpp
index cfc87a7..b568993 100644
--- a/src/zmq_engine.cpp
+++ b/src/zmq_engine.cpp
@@ -101,8 +101,11 @@ void zmq::zmq_engine_t::in_event ()
     insize -= processed;
 
     //  Stop polling for input if we got stuck.
-    if (processed < insize)
-        reset_pollin (handle);
+    if (processed < insize) {
+        zmq_assert (false);
+        //  TODO: This may happen is queue limits are implemented.
+        //  reset_pollin (handle);
+    }
 
     //  Flush all messages the decoder may have produced.
     inout->flush ();