Use new-style register.

diff --git a/controlpi_plugins/wsserver.py b/controlpi_plugins/wsserver.py
index 6e5db0af6bdf6a554a7f7bc80f5f276909d6f198..0fd434e830c93b9e6cbc0726bd4ce787dcedeb1f 100644 (file)
--- a/controlpi_plugins/wsserver.py
+++ b/controlpi_plugins/wsserver.py
@@ -35,8 +35,9 @@ class Connection:
         self._port = address[1]
         self._name = f"{self._address}:{self._port}"
         self._bus.register(self._name, 'WSServer',
-                           [MessageTemplate()], [MessageTemplate()],
-                           self._receive)
+                           [MessageTemplate()],
+                           [([MessageTemplate()],
+                             self._receive)])
 
     async def _receive(self, message: Message) -> None:
         """Receive messages from bus and relay to websocket."""
@@ -76,13 +77,13 @@ class Connection:
                         sends.append(template)
                     try:
                         self._bus.register(self._name, 'WSServer', sends,
-                                           message['down filter'],
-                                           self._receive)
+                                           [(message['down filter'],
+                                             self._receive)])
                     except BusException:
                         self._bus.unregister(self._name)
                         self._bus.register(self._name, 'WSServer', sends,
-                                           message['down filter'],
-                                           self._receive)
+                                           [(message['down filter'],
+                                             self._receive)])
                     open_message = Message(self._name)
                     open_message['event'] = 'connection opened'
                     open_message['address'] = self._address