diff --git a/message_queue.py b/message_queue.py
index acb91c8..50ee2b3 100644
--- a/message_queue.py
+++ b/message_queue.py
@@ -64,7 +64,7 @@ class SocketWrapper:
         LOG.debug("Connecting to {}:{}".format(self.host, self.port))
         self.soc = _try_with_backoff(
             lambda: socket.create_connection((self.host, self.port)),
-            lambda e: e is OSError and e.errno == 111,
+            lambda e: isinstance(e, OSError) and e.errno == 111,
         )
         LOG.info("Socket Connected")
 
@@ -72,7 +72,7 @@ class SocketWrapper:
         LOG.info("Server Binding to {}:{}".format(self.host, self.port))
         self.soc = _try_with_backoff(
             lambda: socket_create_server((self.host, self.port)),
-            lambda e: e is OSError and e.errno == 98,
+            lambda e: isinstance(e, OSError) and e.errno == 98,
         )
         LOG.info("Server Bound")