diff --git a/uds/uds_communications/TransportProtocols/Can/CanConnection.py b/uds/uds_communications/TransportProtocols/Can/CanConnection.py
index f1c6bea..05ab9e2 100644
--- a/uds/uds_communications/TransportProtocols/Can/CanConnection.py
+++ b/uds/uds_communications/TransportProtocols/Can/CanConnection.py
@@ -52,3 +52,7 @@ def transmit(self, data, reqId, extended=False):
 
         self.__bus.send(canMsg)
 
+    def close(self):
+        self.__notifier.stop()
+        for listener in self.__listeners:
+            listener.stop()
diff --git a/uds/uds_communications/TransportProtocols/Can/CanTp.py b/uds/uds_communications/TransportProtocols/Can/CanTp.py
index 58c6f0e..e4a3487 100644
--- a/uds/uds_communications/TransportProtocols/Can/CanTp.py
+++ b/uds/uds_communications/TransportProtocols/Can/CanTp.py
@@ -351,6 +351,7 @@ def recv(self, timeout_s):
     def closeConnection(self):
         # deregister filters, listeners and notifiers etc
         # close can connection
+        self.__connection.close()
         pass
 
     ##