Sunday, March 7, 2021

ZMQ Message Debug

# zmqPUSH.py

import zmq
import datetime
import time
import signal
import pmt

print("Current libzmq version is %s" % zmq.zmq_version())
print("Current pyzmq version is %s" % zmq.__version__)

context = zmq.Context()

# create socket
sock = context.socket(zmq.PUSH)
sock.bind("tcp://127.0.0.1:5558")

while True:
_tim = datetime.datetime.now()
_out = str(_tim)
message = str.encode (_out)
try:
#sock.send (message)
sock.send (pmt.serialize_str(pmt.to_pmt('Hello World!')))
print('sending....')
time.sleep(1)
except KeyboardInterrupt:
print ("interrupt received. shutting down.")
# clean up
sock.close()
context.term()
exit()
Hi all,

I am sending messages from an external application via (ZMQ PUSH) and received those messages in the GNURadio via ZMQ Pull message source. 

From the ZMQ PULL side, I had correctly debugged the message coming from external applications.

I want to basically transmit those messages. But in the receiver side after the Tagged stream to PDU ->  message debug block don't print anything. I put a QT Freq sink to check if the data is coming properly or not.  

Did I miss something? How can I properly debug the messages. I had attached my flow graph.

Any suggestions are welcome.

With Regards,
Jay Patel

No comments:

Post a Comment