diff --git a/kombu/connection.py b/kombu/connection.py index 8b721edc..f051dc8c 100644 --- a/kombu/connection.py +++ b/kombu/connection.py @@ -700,6 +700,9 @@ class Connection(object): self._debug('connection established: %r', self) return conn + def supports_exchange_type(self, exchange_type): + return exchange_type in self.transport.implements.exchange_type + def __repr__(self): """``x.__repr__() <==> repr(x)``""" return ''.format(self.as_uri(), id(self))