# HG changeset patch
# User drewp@bigasterisk.com
# Date 2018-06-09 02:01:36
# Node ID d6ec468112cb127f4fdacfc017f3da0bfb43000c
# Parent  1692e8aba9f5f54a8b48c115f1b91a1f43305083

not sure highwatermark setting did what i wanted
Ignore-this: 3a3b2835ea3a30d7fb0e2007a3b06bb2

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):