python-zeroconf
diff --git a/‎src/zeroconf/_engine.py
Copy file name to clipboardExpand all lines: src/zeroconf/_engine.py
+15-4Lines changed: 15 additions & 4 deletions b/‎src/zeroconf/_engine.py
Copy file name to clipboardExpand all lines: src/zeroconf/_engine.py
+15-4Lines changed: 15 additions & 4 deletions
diff --git a/‎tests/test_engine.py
Copy file name to clipboardExpand all lines: tests/test_engine.py
+16-2Lines changed: 16 additions & 2 deletions b/‎tests/test_engine.py
Copy file name to clipboardExpand all lines: tests/test_engine.py
+16-2Lines changed: 16 additions & 2 deletions
@@ -150,7 +150,9 @@ async def _async_create_endpoints(self) -> None:
             sender_sockets.append(s)
 
         for s in reader_sockets:
-            transport, protocol = await loop.create_datagram_endpoint(lambda: AsyncListener(self.zc), sock=s)
+            transport, protocol = await loop.create_datagram_endpoint(
+                lambda: AsyncListener(self.zc), sock=s  # type: ignore[arg-type, return-value]
+            )
             self.protocols.append(cast(AsyncListener, protocol))
             self.readers.append(_make_wrapped_transport(cast(asyncio.DatagramTransport, transport)))
             if s in sender_sockets:
@@ -198,7 +200,7 @@ def close(self) -> None:
         run_coro_with_timeout(self._async_close(), self.loop, _CLOSE_TIMEOUT)
 
 
-class AsyncListener(asyncio.Protocol, QuietLogger):
+class AsyncListener:
 
     """A Listener is used by this module to listen on the multicast
     group to which DNS messages are sent, allowing the implementation
@@ -207,7 +209,16 @@ class AsyncListener(asyncio.Protocol, QuietLogger):
     It requires registration with an Engine object in order to have
     the read() method called when a socket is available for reading."""
 
-    __slots__ = ('zc', 'data', 'last_time', 'transport', 'sock_description', '_deferred', '_timers')
+    __slots__ = (
+        'zc',
+        'data',
+        'last_time',
+        'last_message',
+        'transport',
+        'sock_description',
+        '_deferred',
+        '_timers',
+    )
 
     def __init__(self, zc: 'Zeroconf') -> None:
         self.zc = zc
@@ -357,7 +368,7 @@ def error_received(self, exc: Exception) -> None:
         # different socket in case there are problems with multiple
         # sockets
         msg_str = f"Error with socket {self.sock_description}): %s"
-        self.log_exception_once(exc, msg_str, exc)
+        QuietLogger.log_exception_once(exc, msg_str, exc)
 
     def connection_made(self, transport: asyncio.BaseTransport) -> None:
         wrapped_transport = _make_wrapped_transport(cast(asyncio.DatagramTransport, transport))
 
@@ -8,14 +8,15 @@
 import logging
 import unittest
 import unittest.mock
-from typing import Set
+from typing import Set, Tuple, Union
 from unittest.mock import MagicMock, patch
 
 import pytest
 
 import zeroconf as r
 from zeroconf import Zeroconf, _engine, const, current_time_millis
 from zeroconf._protocol import outgoing
+from zeroconf._protocol.incoming import DNSIncoming
 from zeroconf.asyncio import AsyncZeroconf
 
 log = logging.getLogger('zeroconf')
@@ -188,7 +189,20 @@ def test_guard_against_duplicate_packets():
     These packets can quickly overwhelm the system.
     """
     zc = Zeroconf(interfaces=['127.0.0.1'])
-    listener = _engine.AsyncListener(zc)
+
+    class SubListener(_engine.AsyncListener):
+        def handle_query_or_defer(
+            self,
+            msg: DNSIncoming,
+            addr: str,
+            port: int,
+            transport: _engine._WrappedTransport,
+            v6_flow_scope: Union[Tuple[()], Tuple[int, int]] = (),
+        ) -> None:
+            """Handle a query or defer it for later processing."""
+            super().handle_query_or_defer(msg, addr, port, transport, v6_flow_scope)
+
+    listener = SubListener(zc)
     listener.transport = MagicMock()
 
     query = r.DNSOutgoing(const._FLAGS_QR_QUERY, multicast=True)