diff --git a/milan/utils/json_rpc.py b/milan/utils/json_rpc.py
index c41a334..3ebde7a 100644
--- a/milan/utils/json_rpc.py
+++ b/milan/utils/json_rpc.py
@@ -417,8 +417,8 @@ def __init__(self, loop, url):
         self._stopped = asyncio.Future(loop=self.loop)
         self._websocket_open = asyncio.Future(loop=self.loop)
         self._websocket = None
-        self._read_queue = asyncio.Queue()
-        self._write_queue = asyncio.Queue()
+        self._read_queue = asyncio.Queue(loop=self.loop)
+        self._write_queue = asyncio.Queue(loop=self.loop)
 
         self.loop.create_task(coro=self._handle_read_queue())
         self.loop.create_task(coro=self._handle_write_queue())