diff options
| -rw-r--r-- | kombu/transport/azureservicebus.py | 8 |
1 files changed, 7 insertions, 1 deletions
diff --git a/kombu/transport/azureservicebus.py b/kombu/transport/azureservicebus.py index f022ebb4..3c0c7136 100644 --- a/kombu/transport/azureservicebus.py +++ b/kombu/transport/azureservicebus.py @@ -29,9 +29,15 @@ from kombu.utils.objects import cached_property from . import virtual try: + # azure-servicebus version <= 0.21.1 from azure.servicebus import ServiceBusService, Message, Queue except ImportError: - ServiceBusService = Message = Queue = None + try: + # azure-servicebus version >= 0.50.0 + from azure.servicebus.control_client import \ + ServiceBusService, Message, Queue + except ImportError: + ServiceBusService = Message = Queue = None # dots are replaced by dash, all other punctuation replaced by underscore. CHARS_REPLACE_TABLE = { |