diff --git a/meteos/rpc.py b/meteos/rpc.py index 0a5984e..f13cb75 100644 --- a/meteos/rpc.py +++ b/meteos/rpc.py @@ -45,7 +45,7 @@ EXTRA_EXMODS = [] def init(conf): global TRANSPORT, NOTIFIER exmods = get_allowed_exmods() - TRANSPORT = messaging.get_transport(conf, + TRANSPORT = messaging.get_rpc_transport(conf, allowed_remote_exmods=exmods) serializer = RequestContextSerializer(JsonPayloadSerializer()) NOTIFIER = messaging.Notifier(TRANSPORT, serializer=serializer)