diff --git a/bin/collector b/bin/collector
--- a/bin/collector
+++ b/bin/collector
@@ -49,7 +49,7 @@ def startZmq(port, collector):
     log.info('creating zmq endpoint at %r', addr)
     e = ZmqEndpoint('bind', addr)
     class Pull(ZmqPullConnection):
-        highWaterMark = 3
+        #highWaterMark = 3
         def onPull(self, message):
             with stats.setAttr.time():
                 # todo: new compressed protocol where you send all URIs up
diff --git a/light9/dmxclient.py b/light9/dmxclient.py
--- a/light9/dmxclient.py
+++ b/light9/dmxclient.py
@@ -22,7 +22,7 @@ class TwistedZmqClient(object):
         zf = ZmqFactory()
         e = ZmqEndpoint('connect', 'tcp://%s:%s' % (service.host, service.port))
         class Push(ZmqPushConnection):
-            highWaterMark = 3
+            pass # highWaterMark = 3000
         self.conn = Push(zf, e)
         
     def send(self, clientid, levellist):