X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=examples%2Frmr%2Frcv_all.py;h=8a33435e3901a231097caa3ebf9d7ff3ba9ebce7;hb=refs%2Fchanges%2F64%2F4864%2F3;hp=1db982f96e6d5780948b881dd8bdca471d36e77a;hpb=fbb5928134d64dbab8bc3e64b23c2f21e4c4be6f;p=ric-plt%2Fxapp-frame-py.git diff --git a/examples/rmr/rcv_all.py b/examples/rmr/rcv_all.py index 1db982f..8a33435 100644 --- a/examples/rmr/rcv_all.py +++ b/examples/rmr/rcv_all.py @@ -1,4 +1,3 @@ -# vim: ts=4 sw=4 expandtab: # ================================================================================== # Copyright (c) 2019 Nokia # Copyright (c) 2018-2019 AT&T Intellectual Property. @@ -27,10 +26,6 @@ # Because this programme does not send messages, there is no reason # to wait for RMR to initialise a route table (no call to rmr_ready # is needed. -# -# Date: 26 September 2019 -# -# --------------------------------------------------------------------------------- from rmr import rmr from rmr import helpers @@ -64,7 +59,7 @@ while True: else: print( "got %d messages" % len( mbunch ) ) for mb in mbunch: - print( "type=%d payload=%s" % (mb["message type"], mb["payload"] ) ) + print( "type=%d payload=%s" % (mb[rmr.RMR_MS_MSG_TYPE], mb[rmr.RMR_MS_PAYLOAD] ) ) time.sleep( 1 ) # sleep to allow some to accumulate