Rooba
/
kombu
mirror of https://github.com/celery/kombu.git
1
1
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Adds Connection.supports_exchange_type(type)

This commit is contained in:
Ask Solem 2015-10-26 19:39:55 -07:00
parent cab0afab00
commit 4b41cb0992
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
kombu/connection.py
View File

@ -700,6 +700,9 @@ class Connection(object):
self._debug('connection established: %r', self) self._debug('connection established: %r', self)
return conn return conn
def supports_exchange_type(self, exchange_type):
return exchange_type in self.transport.implements.exchange_type
def __repr__(self): def __repr__(self):
"""``x.__repr__() <==> repr(x)``""" """``x.__repr__() <==> repr(x)``"""
return '<Connection: {0} at {1:#x}>'.format(self.as_uri(), id(self)) return '<Connection: {0} at {1:#x}>'.format(self.as_uri(), id(self))