From a6a7ab255bf1e5a45d36f79bd66c121fb6e05c9f 2022-11-16 16:46:34
From: Juan C. Espinoza <juan.espinoza@jro.igp.gob.pe>
Date: 2022-11-16 16:46:34
Subject: [PATCH] change push/pull by pub/sub in VoltageReader ZMQ

---

diff --git a/schainpy/model/io/jroIO_voltage.py b/schainpy/model/io/jroIO_voltage.py
index ea77b0b..f7acdaf 100644
--- a/schainpy/model/io/jroIO_voltage.py
+++ b/schainpy/model/io/jroIO_voltage.py
@@ -296,7 +296,7 @@ class VoltageReader(JRODataReader, ProcessingUnit):
         self.nReadBlocks += 1
         self.blockPointer = 0
 
-        block = self.receiver.recv()
+        topic, block = self.receiver.recv_multipart()
 
         self.basicHeaderObj.read(block[self.blockPointer:])
         self.blockPointer += self.basicHeaderObj.length
@@ -309,7 +309,7 @@ class VoltageReader(JRODataReader, ProcessingUnit):
         self.readFirstHeaderFromServer()
 
         timestamp = self.basicHeaderObj.get_datatime()
-        print('[Receiving] - Block {} - {}'.format(self.nTotalBlocks, timestamp))
+        print('[Receiving] - Block {} - {} from {}'.format(self.nTotalBlocks, timestamp, topic.decode()))
         if self.nTotalBlocks == self.processingHeaderObj.dataBlocksPerFile:
             self.nTotalBlocks = 0
             self.nReadBlocks = 0