##// END OF EJS Templates
fix zmq protocol
Juan C. Valdez -
r886:411fb11610ee
parent child
Show More
@@ -16,7 +16,7 from multiprocessing import Process
16 16
17 17 from schainpy.model.proc.jroproc_base import Operation, ProcessingUnit
18 18
19 throttle_value = 10
19 throttle_value = 5
20 20
21 21 class PrettyFloat(float):
22 22 def __repr__(self):
@@ -147,7 +147,7 class PublishData(Operation):
147 147 self.zmq_socket = context.socket(zmq.PUSH)
148 148 server = kwargs.get('server', 'zmq.pipe')
149 149
150 if 'http://' in server:
150 if 'tcp://' in server:
151 151 address = server
152 152 else:
153 153 address = 'ipc:///tmp/%s' % server
General Comments 0
You need to be logged in to leave comments. Login now