[EventHubs] uamqp switch support

sdk/eventhub/azure-eventhub/CHANGELOG.md

@@ -2,16 +2,14 @@
 
 ## 5.10.1 (Unreleased)
 
-### Features Added
-
-### Breaking Changes
+### Bugs Fixed
 
 - Fixed a bug in `BufferedProducer` that would block when flushing the queue causing the client to freeze up (issue #23510).
 
-### Bugs Fixed
-
 ### Other Changes
 
+- Internal refactoring to support upcoming Pure Python AMQP-based release.
+
 ## 5.10.0 (2022-06-08)
 
 ### Features Added

sdk/eventhub/azure-eventhub/azure/eventhub/__init__.py

@@ -2,12 +2,12 @@
 # Copyright (c) Microsoft Corporation. All rights reserved.
 # Licensed under the MIT License. See License.txt in the project root for license information.
 # --------------------------------------------------------------------------------------------
-from uamqp import constants
 from ._common import EventData, EventDataBatch
 from ._version import VERSION
 
 __version__ = VERSION
 
+from ._constants import TransportType
 from ._producer_client import EventHubProducerClient
 from ._consumer_client import EventHubConsumerClient
 from ._client_base import EventHubSharedKeyCredential
@@ -19,8 +19,6 @@
     EventHubConnectionStringProperties,
 )
 
-TransportType = constants.TransportType
-
 __all__ = [
     "EventData",
     "EventDataBatch",

sdk/eventhub/azure-eventhub/azure/eventhub/_buffered_producer/_buffered_producer.py

@@ -2,6 +2,7 @@
 # Copyright (c) Microsoft Corporation. All rights reserved.
 # Licensed under the MIT License. See License.txt in the project root for license information.
 # --------------------------------------------------------------------------------------------
+from __future__ import annotations
 import time
 import queue
 import logging
@@ -14,6 +15,7 @@
 from ..exceptions import OperationTimeoutError
 
 if TYPE_CHECKING:
+    from .._transport._base import AmqpTransport
     from .._producer_client import SendEventTypes
 
 _LOGGER = logging.getLogger(__name__)
@@ -30,8 +32,8 @@ def __init__(
         max_message_size_on_link: int,
         executor: ThreadPoolExecutor,
         *,
-        max_wait_time: float = 1,
-        max_buffer_length: int
+        max_buffer_length: int,
+        max_wait_time: float = 1
     ):
         self._buffered_queue: queue.Queue = queue.Queue()
         self._max_buffer_len = max_buffer_length

sdk/eventhub/azure-eventhub/azure/eventhub/_buffered_producer/_buffered_producer_dispatcher.py

@@ -2,6 +2,7 @@
 # Copyright (c) Microsoft Corporation. All rights reserved.
 # Licensed under the MIT License. See License.txt in the project root for license information.
 # --------------------------------------------------------------------------------------------
+from __future__ import annotations
 import logging
 from threading import Lock
 from concurrent.futures import ThreadPoolExecutor
@@ -14,6 +15,7 @@
 
 if TYPE_CHECKING:
     from .._producer_client import SendEventTypes
+    from .._transport._base import AmqpTransport
 
 _LOGGER = logging.getLogger(__name__)