X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=ricxappframe%2Fxapp_frame.py;fp=ricxappframe%2Fxapp_frame.py;h=b81804e7dc230bb438939cf643e39328ae2de19a;hb=61270901cda095afdd3ce147bf0dfd628c84cf99;hp=58596b8c398afc3260b45734514e74bd4ae2e819;hpb=666e8319bd0e618576be79a14208d7eaf0de99f2;p=ric-plt%2Fxapp-frame-py.git diff --git a/ricxappframe/xapp_frame.py b/ricxappframe/xapp_frame.py index 58596b8..b81804e 100644 --- a/ricxappframe/xapp_frame.py +++ b/ricxappframe/xapp_frame.py @@ -1,7 +1,3 @@ -""" -Framework for python xapps -Framework here means Xapp classes that can be subclassed -""" # ================================================================================== # Copyright (c) 2020 Nokia # Copyright (c) 2020 AT&T Intellectual Property. @@ -18,10 +14,15 @@ Framework here means Xapp classes that can be subclassed # See the License for the specific language governing permissions and # limitations under the License. # ================================================================================== +""" +Framework for python xapps +Framework here means Xapp classes that can be subclassed +""" + from threading import Thread from ricxappframe import xapp_rmr -from ricxappframe.xapp_sdl import SDLWrapper from ricxappframe.rmr import rmr +from ricxappframe.xapp_sdl import SDLWrapper from mdclogpy import Logger # constants @@ -337,7 +338,7 @@ class RMRXapp(_BaseXapp): if not self._rmr_loop.rcv_queue.empty(): (summary, sbuf) = self._rmr_loop.rcv_queue.get() # dispatch - func = self._dispatch.get(summary["message type"], None) + func = self._dispatch.get(summary[rmr.RMR_MS_MSG_TYPE], None) if not func: func = self._default_handler func(self, summary, sbuf)