X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=examples%2Frmr%2Freceive.py;fp=examples%2Frmr%2Freceive.py;h=ac008786868fceb03cb2b28138d0a57a65f6d355;hb=61270901cda095afdd3ce147bf0dfd628c84cf99;hp=ae3130934c97c79ae89d10e9e5dd3b9b25e124c1;hpb=666e8319bd0e618576be79a14208d7eaf0de99f2;p=ric-plt%2Fxapp-frame-py.git diff --git a/examples/rmr/receive.py b/examples/rmr/receive.py index ae31309..ac00878 100644 --- a/examples/rmr/receive.py +++ b/examples/rmr/receive.py @@ -20,9 +20,9 @@ import sys import signal -# Demonstrate NNG cleanup +# Demonstrate RMR cleanup def signal_handler(sig, frame): - print("SIGINT received! Cleaning up rmr") + print("SIGINT received! Cleaning up RMR") rmr.rmr_close(mrc) print("Byeee") sys.exit(0) @@ -44,7 +44,7 @@ while True: print("Waiting for a message, will timeout after 2000ms") sbuf = rmr.rmr_torcv_msg(mrc, sbuf, 2000) summary = rmr.message_summary(sbuf) - if summary["message state"] == 12: + if summary[rmr.RMR_MS_MSG_STATE] == 12: print("Nothing received =(") else: print("Message received!: {}".format(summary))