diff --git a/hippolyzer/lib/voice/client.py b/hippolyzer/lib/voice/client.py
index 47bd361..9d5febe 100644
--- a/hippolyzer/lib/voice/client.py
+++ b/hippolyzer/lib/voice/client.py
@@ -75,7 +75,7 @@ class VoiceClient:
 
         self.vivox_conn: Optional[VivoxConnection] = None
         self._poll_task = asyncio.get_event_loop().create_task(self._poll_messages())
-        self.message_handler: MessageHandler[VivoxMessage, str] = MessageHandler()
+        self.message_handler: MessageHandler[VivoxMessage, str] = MessageHandler(take_by_default=False)
 
     @property
     def username(self):
diff --git a/tests/voice/test_voice.py b/tests/voice/test_voice.py
index d165766..75a05e5 100644
--- a/tests/voice/test_voice.py
+++ b/tests/voice/test_voice.py
@@ -207,32 +207,55 @@ class TestVoiceClient(unittest.IsolatedAsyncioTestCase):
         })
         await self.client.ready.wait()
 
+    async def _serve_login(self):
+        msg = await self._expect_message("Account.Login.1")
+        self.assertEqual("foo", msg.data["AccountName"])
+        await self.server_connection.send_event("AccountLoginStateChangeEvent", {
+            "AccountHandle": 2,
+            "StatusCode": 200,
+            "StatusString": "OK",
+            "State": 1,
+        })
+        await self.server_connection.send_response(msg.request_id, msg.name, {
+            "ReturnCode": 0,
+            "Results": {
+                "StatusCode": 0,
+                "StatusString": None,
+                "AccountHandle": 2,
+                "DisplayName": "foo",
+            }
+        })
+
     async def test_create_connector(self):
         await self._serve_connector_setup()
 
     async def test_login(self):
         await self._serve_connector_setup()
-
-        async def _handle_login():
-            msg = await self._expect_message("Account.Login.1")
-            self.assertEqual("foo", msg.data["AccountName"])
-            await self.server_connection.send_event("AccountLoginStateChangeEvent", {
-                "AccountHandle": 2,
-                "StatusCode": 200,
-                "StatusString": "OK",
-                "State": 1,
-            })
-            await self.server_connection.send_response(msg.request_id, msg.name, {
-                "ReturnCode": 0,
-                "Results": {
-                    "StatusCode": 0,
-                    "StatusString": None,
-                    "AccountHandle": 2,
-                    "DisplayName": "foo",
-                }
-            })
-
-        login_task = asyncio.get_event_loop().create_task(_handle_login())
+        login_task = asyncio.create_task(self._serve_login())
 
         await asyncio.wait_for(self.client.login("foo", "bar"), 0.5)
         await asyncio.wait_for(login_task, 0.5)
+
+    async def test_create_session(self):
+        await self._serve_connector_setup()
+        login_task = asyncio.create_task(self._serve_login())
+
+        await asyncio.wait_for(self.client.login("foo", "bar"), 0.5)
+        await asyncio.wait_for(login_task, 0.5)
+
+        async def _serve_session():
+            await self._handle_message("Session.Create.1")
+            await self.server_connection.send_event("SessionAddedEvent", {
+                "SessionHandle": 4,
+                "SessionGroupHandle": 5,
+            })
+            await self.server_connection.send_event("ParticipantAddedEvent", {
+                "ParticipantUri": "uri:baz@foo",
+            })
+
+        serve_session_task = asyncio.create_task(_serve_session())
+
+        await self.client.join_session("uri:foo@bar", region_handle=0)
+        self.assertIn("uri:baz@foo", self.client.participants)
+
+        await serve_session_task