From 411fb11610ee039ae4a7ecf8250444382befd20d 2017-04-19 19:56:55
From: Juan C. Valdez <juan.espinoza@jro.igp.gob.pe>
Date: 2017-04-19 19:56:55
Subject: [PATCH] fix zmq protocol

---

diff --git a/schainpy/model/utils/jroutils_publish.py b/schainpy/model/utils/jroutils_publish.py
index f42f793..a9088a4 100644
--- a/schainpy/model/utils/jroutils_publish.py
+++ b/schainpy/model/utils/jroutils_publish.py
@@ -16,7 +16,7 @@ from multiprocessing import Process
 
 from schainpy.model.proc.jroproc_base import Operation, ProcessingUnit
 
-throttle_value = 10
+throttle_value = 5
 
 class PrettyFloat(float):
     def __repr__(self):
@@ -147,7 +147,7 @@ class PublishData(Operation):
             self.zmq_socket = context.socket(zmq.PUSH)
             server = kwargs.get('server', 'zmq.pipe')
             
-            if 'http://' in server:
+            if 'tcp://' in server:
                 address = server
             else:
                 address = 'ipc:///tmp/%s' % server