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