diff --git a/kombu/async/hub.py b/kombu/async/hub.py
index 94b62f52..bc94c774 100644
--- a/kombu/async/hub.py
+++ b/kombu/async/hub.py
@@ -303,6 +303,7 @@ class Hub(object):
                             except TypeError:
                                 pass
                     except (KeyError, Empty):
+                        hub_remove(fileno)
                         continue
                     if cb is None:
                         continue
diff --git a/kombu/connection.py b/kombu/connection.py
index a9771be9..bdfc38bc 100644
--- a/kombu/connection.py
+++ b/kombu/connection.py
@@ -23,7 +23,6 @@ except ImportError:  # Py2
 # jython breaks on relative import for .exceptions for some reason
 # (Issue #112)
 from kombu import exceptions
-from .async import get_event_loop
 from .five import Empty, range, string_t, text_t, LifoQueue as _LifoQueue
 from .log import get_logger
 from .transport import get_transport_cls, supports_librabbitmq
@@ -702,9 +701,6 @@ class Connection(object):
     def _establish_connection(self):
         self._debug('establishing connection...')
         conn = self.transport.establish_connection()
-        loop = get_event_loop()
-        if loop:
-            self.transport.register_with_event_loop(conn, loop)
         self._debug('connection established: %r', conn)
         return conn
 
diff --git a/kombu/transport/base.py b/kombu/transport/base.py
index 0b22167d..6fe54e8b 100644
--- a/kombu/transport/base.py
+++ b/kombu/transport/base.py
@@ -123,6 +123,9 @@ class Transport(object):
     def register_with_event_loop(self, loop):
         pass
 
+    def unregister_from_event_loop(self, loop):
+        pass
+
     def verify_connection(self, connection):
         return True