print("listening ON {}".format(PORT))
while True:
- sbuf = rmr.rmr_alloc_msg(mrc, 4096)
+ sbuf = rmr.rmr_alloc_msg(mrc, 10)
sbuf = rmr.rmr_torcv_msg(mrc, sbuf, 1000)
summary = rmr.message_summary(sbuf)
if summary["message state"] == 12 and summary["message status"] == "RMR_ERR_TIMEOUT":
val = json.dumps(payload).encode("utf-8")
rmr.set_payload_and_length(val, sbuf)
- sbuf.contents.mtype = 21024
+ sbuf.contents.mtype = 20011
print("Pre reply summary: {}".format(rmr.message_summary(sbuf)))
time.sleep(DELAY)