diff --git a/zaqar/transport/websocket/protocol.py b/zaqar/transport/websocket/protocol.py index 8fbee7330..5a01cc13f 100644 --- a/zaqar/transport/websocket/protocol.py +++ b/zaqar/transport/websocket/protocol.py @@ -21,6 +21,7 @@ from autobahn.asyncio import websocket from oslo_log import log as logging from oslo_utils import timeutils import pytz +import txaio try: import asyncio @@ -51,6 +52,7 @@ class MessagingProtocol(websocket.WebSocketServerProtocol): } def __init__(self, handler, proto_id, auth_strategy, loop): + txaio.use_asyncio() websocket.WebSocketServerProtocol.__init__(self) self._handler = handler self.proto_id = proto_id