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":
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)
val = json.dumps(payload).encode("utf-8")
rmr.set_payload_and_length(val, sbuf)