diff --git a/kombu/transport/qpid.py b/kombu/transport/qpid.py index 524fab04..3eaaf914 100644 --- a/kombu/transport/qpid.py +++ b/kombu/transport/qpid.py @@ -1408,6 +1408,7 @@ class Transport(base.Transport): # This Transport does support the Celery asynchronous event model. implements = virtual.Transport.implements.extend( asynchronous=True, + exchange_type=frozenset(['direct', 'topic', 'fanout']), ) # The driver type and name for identification purposes. diff --git a/t/unit/transport/test_qpid.py b/t/unit/transport/test_qpid.py index 874ebc60..e2999c3e 100644 --- a/t/unit/transport/test_qpid.py +++ b/t/unit/transport/test_qpid.py @@ -1667,6 +1667,12 @@ class test_Transport_class_attributes(object): assert Transport.driver_type == 'qpid' assert Transport.driver_name == 'qpid' + def test_verify_implements_exchange_types(self): + assert 'fanout' in Transport.implements.exchange_type + assert 'direct' in Transport.implements.exchange_type + assert 'topic' in Transport.implements.exchange_type + assert 'frobnitz' not in Transport.implements.exchange_type + def test_transport_verify_recoverable_connection_errors(self): connection_errors = Transport.recoverable_connection_errors assert ConnectionError in connection_errors