diff --git a/sdk/servicebus/azure-servicebus/CHANGELOG.md b/sdk/servicebus/azure-servicebus/CHANGELOG.md index 7a98b46f5384..908c8fc4d079 100644 --- a/sdk/servicebus/azure-servicebus/CHANGELOG.md +++ b/sdk/servicebus/azure-servicebus/CHANGELOG.md @@ -1,11 +1,16 @@ # Release History -## 7.15.0b3 (Unreleased) +## 7.15.0 (2026-10-06) ### Features Added - Added an opt-in `try_timeout` client keyword that bounds a single attempt rather than the whole operation. Applies to sending, management operations, and AMQP link acquisition, where the wait for the link to become ready was previously unbounded. Each attempt gets a fresh `try_timeout`, still capped by the caller's remaining time; exceeding it raises a retryable `OperationTimeoutError` and retries. Must be greater than 0 if specified, and defaults to `None` (off), preserving existing behavior. It also caps the link acquisition performed by `receive_messages()` and by receiver iteration, but does not bound the `receive_messages()` long poll, the iterator's own wait, or message settlement. Opening, closing and error-path cleanup of the AMQP handler are bounded on the async client, where a slow call is cancelled once the budget is spent and a cleanup failure never replaces the error that triggered it; the sync client cannot interrupt a blocking call and so detects the overrun only once it returns. Mirrors `TryTimeout` in the .NET, Java and Go SDKs. +- Added `ServiceBusReceivedMessage.from_bytes()` classmethod to construct a `ServiceBusReceivedMessage` from raw AMQP payload bytes without requiring the deprecated `uamqp` library. ([#43979](https://github.com/Azure/azure-sdk-for-python/issues/43979)) +- Added `ServiceBusClient.list_queue_sessions()` and `ServiceBusClient.list_subscription_sessions()` (sync and async) to list session IDs for entities with active messages or stored session state, with optional filtering by session-state update timestamp. The methods return an `ItemPaged[str]` (`AsyncItemPaged[str]` on the async client) so callers can iterate every session transparently or page with `by_page()`. Implements the `com.microsoft:get-message-sessions` management operation. ([#46575](https://github.com/Azure/azure-sdk-for-python/pull/46575)) +- Added `sql_filter_count` and `correlation_filter_count` properties to `TopicRuntimeProperties`, exposing the total number of SQL filters and correlation filters across all of a topic's subscriptions. +- Added API version `2024-05` and made it the default for the management client, which is required for the topic filter counts above. + ### Breaking Changes - `receive_messages()` now returns an empty list after 60 seconds when no wait time was given on the call or the receiver; it previously had no deadline and blocked until a message arrived or the connection closed. An explicit `max_wait_time` still wins, and receiver iteration is unchanged. On a receiver that has not been opened yet, this wait now also bounds the initial link acquisition, including connecting to a `NEXT_AVAILABLE_SESSION`; open the receiver first (for example with a context manager) to keep that governed solely by the constructor's `max_wait_time`. @@ -14,19 +19,6 @@ - Management, send and receive operations now bound AMQP link acquisition by the caller's timeout, rather than timing only the operation that follows it. Previously a link that never became ready could block indefinitely even when a timeout was supplied. Management and send deduct the time spent from the operation itself, so one attempt shares a single budget. -### Other Changes - -## 7.15.0b2 (2026-08-21) - -### Features Added - -- Added `ServiceBusReceivedMessage.from_bytes()` classmethod to construct a `ServiceBusReceivedMessage` from raw AMQP payload bytes without requiring the deprecated `uamqp` library. ([#43979](https://github.com/Azure/azure-sdk-for-python/issues/43979)) -- Added `ServiceBusClient.list_queue_sessions()` and `ServiceBusClient.list_subscription_sessions()` (sync and async) to list session IDs for entities with active messages or stored session state, with optional filtering by session-state update timestamp. The methods return an `ItemPaged[str]` (`AsyncItemPaged[str]` on the async client) so callers can iterate every session transparently or page with `by_page()`. Implements the `com.microsoft:get-message-sessions` management operation. ([#46575](https://github.com/Azure/azure-sdk-for-python/pull/46575)) -- Added `sql_filter_count` and `correlation_filter_count` properties to `TopicRuntimeProperties`, exposing the total number of SQL filters and correlation filters across all of a topic's subscriptions. -- Added API version `2024-05` and made it the default for the management client, which is required for the topic filter counts above. - -### Bugs Fixed - - Fixed a bug where messages returned by `receive_deferred_messages` had a `lock_token` of `None`, which prevented settling (completing, abandoning, dead-lettering, deferring) or renewing the lock on a deferred message in `PEEK_LOCK` mode. The lock token is now read from the `lock-token` field of the management-link response for deferred messages. ([#42454](https://github.com/Azure/azure-sdk-for-python/issues/42454)) - Read `com.microsoft:max-message-batch-size` vendor property from the AMQP sender link to correctly limit batch size on Premium large-message entities, where `max-message-size` can be up to 100 MB but the batch limit is 1 MB. - Fixed a bug where sending a batched or multi-message payload with `uamqp_transport=True` raised `TypeError: 'BatchMessage' object is not subscriptable` (and a masked `AttributeError` on the list path) when the first message carried a `message_id`, `session_id`, or `partition_key`. The batch envelope properties are now set through the transport-appropriate code path. (regression from [#42598](https://github.com/Azure/azure-sdk-for-python/pull/42598)) @@ -43,6 +35,7 @@ - Clarified in the `application_properties` documentation (the `ServiceBusMessage` constructor, the `application_properties` property, and the README) that when a message is received, its keys and any string values are returned as `bytes`, not `str`, along with the recommended bytes-key access and decoding pattern. ([#45082](https://github.com/Azure/azure-sdk-for-python/issues/45082)) - When using the async `AmqpOverWebsocket` transport on Python 3.10 or later, `aiohttp>=3.14.0` is now recommended. Earlier `aiohttp` versions have a WebSocket heartbeat bug ([aio-libs/aiohttp#12030](https://github.com/aio-libs/aiohttp/pull/12030)) that can cause the connection to be dropped during long message processing, surfacing as a `SocketError` ("Cannot write to closing transport"). Python 3.9 users must upgrade Python to install an `aiohttp` release containing this fix. ([#44028](https://github.com/Azure/azure-sdk-for-python/issues/44028)) - Management operations (peek, deferred receive, message settlement over the management link, lock renewal, session state, session listing, schedule/cancel) now send `com.microsoft:server-timeout`: the caller's remaining time less one second, or 60 seconds when none was given. Previously no bound was sent, so a stalled service held the call until the AMQP link failed; it now raises a retryable `OperationTimeoutError`, so a persistently stalled service surfaces after roughly four minutes at default retry settings. Matches the .NET, Java and Go SDKs. +- Removed the deprecation warning for the legacy uAMQP transport. The `uamqp_transport=True` option remains available in 7.15.0. ## 7.14.3 (2025-11-11) diff --git a/sdk/servicebus/azure-servicebus/api.metadata.yml b/sdk/servicebus/azure-servicebus/api.metadata.yml index bab122e95f08..114718312c3a 100644 --- a/sdk/servicebus/azure-servicebus/api.metadata.yml +++ b/sdk/servicebus/azure-servicebus/api.metadata.yml @@ -1,4 +1,4 @@ apiMdSha256: a5f9da8d7980799f054d782f99eabf9b190925718f2bc4bdd86f01752a5c1bf8 -packageVersion: 7.15.0b3 +packageVersion: 7.15.0 parserVersion: 0.3.31 pythonVersion: 3.14.0 diff --git a/sdk/servicebus/azure-servicebus/azure/servicebus/_servicebus_client.py b/sdk/servicebus/azure-servicebus/azure/servicebus/_servicebus_client.py index 2ad6b3373bd0..d404e7524f45 100644 --- a/sdk/servicebus/azure-servicebus/azure/servicebus/_servicebus_client.py +++ b/sdk/servicebus/azure-servicebus/azure/servicebus/_servicebus_client.py @@ -6,7 +6,6 @@ from typing import Any, Union, Optional, TYPE_CHECKING, Type from datetime import datetime import logging -import warnings from weakref import WeakSet from typing_extensions import Literal import certifi @@ -136,16 +135,6 @@ def __init__( ) if uamqp_transport: - # Deprecation of uamqp transport - warnings.warn( - "uAMQP legacy support will be removed in the 7.15.0 minor release. " - "Please remove the use of `uamqp_transport` keyword argument from the client in order " - "to use the pure Python AMQP transport. " - "If you rely on this, please comment on [this issue]" - "(https://github.com/Azure/azure-sdk-for-python/issues/40347) ", - DeprecationWarning, - stacklevel=2, - ) try: from ._transport._uamqp_transport import UamqpTransport diff --git a/sdk/servicebus/azure-servicebus/azure/servicebus/_transport/_uamqp_transport.py b/sdk/servicebus/azure-servicebus/azure/servicebus/_transport/_uamqp_transport.py index 8419d0770f07..5f988cf4158f 100644 --- a/sdk/servicebus/azure-servicebus/azure/servicebus/_transport/_uamqp_transport.py +++ b/sdk/servicebus/azure-servicebus/azure/servicebus/_transport/_uamqp_transport.py @@ -895,7 +895,7 @@ def reset_link_credit(handler: "ReceiveClient", link_credit: int) -> None: def drain_and_release_messages(handler: "ReceiveClient") -> None: """ No-op for uamqp: drain-on-close is only implemented for the pyamqp - transport (the default). uamqp is deprecated. + transport (the default). :param ~uamqp.ReceiveClient handler: The handler. :rtype: None """ diff --git a/sdk/servicebus/azure-servicebus/azure/servicebus/_version.py b/sdk/servicebus/azure-servicebus/azure/servicebus/_version.py index 7231fb90d443..bbae47a9af60 100644 --- a/sdk/servicebus/azure-servicebus/azure/servicebus/_version.py +++ b/sdk/servicebus/azure-servicebus/azure/servicebus/_version.py @@ -3,4 +3,4 @@ # Licensed under the MIT License. # ------------------------------------ -VERSION = "7.15.0b3" +VERSION = "7.15.0" diff --git a/sdk/servicebus/azure-servicebus/azure/servicebus/aio/_servicebus_client_async.py b/sdk/servicebus/azure-servicebus/azure/servicebus/aio/_servicebus_client_async.py index 6d3229fa463a..5e95291699d7 100644 --- a/sdk/servicebus/azure-servicebus/azure/servicebus/aio/_servicebus_client_async.py +++ b/sdk/servicebus/azure-servicebus/azure/servicebus/aio/_servicebus_client_async.py @@ -6,7 +6,6 @@ from typing import Any, Union, Optional, TYPE_CHECKING, Type from datetime import datetime import logging -import warnings from weakref import WeakSet from typing_extensions import Literal import certifi @@ -128,16 +127,6 @@ def __init__( ] = PyamqpTransportAsync if uamqp_transport: - # Deprecation of uamqp transport - warnings.warn( - "uAMQP legacy support will be removed in the 7.15.0 minor release. " - "Please remove the use of `uamqp_transport` keyword argument from the client in order " - "to use the pure Python AMQP transport. " - "If you rely on this, please comment on [this issue]" - "(https://github.com/Azure/azure-sdk-for-python/issues/40347) ", - DeprecationWarning, - stacklevel=2, - ) try: from ._transport._uamqp_transport_async import UamqpTransportAsync diff --git a/sdk/servicebus/azure-servicebus/azure/servicebus/aio/_transport/_uamqp_transport_async.py b/sdk/servicebus/azure-servicebus/azure/servicebus/aio/_transport/_uamqp_transport_async.py index 02ba9be7e4fa..bd3b42aaeed6 100644 --- a/sdk/servicebus/azure-servicebus/azure/servicebus/aio/_transport/_uamqp_transport_async.py +++ b/sdk/servicebus/azure-servicebus/azure/servicebus/aio/_transport/_uamqp_transport_async.py @@ -281,7 +281,7 @@ async def reset_link_credit_async(handler: "ReceiveClientAsync", link_credit: in async def drain_and_release_messages_async(handler: "ReceiveClientAsync") -> None: """ No-op for uamqp: drain-on-close is only implemented for the pyamqp - transport (the default). uamqp is deprecated. + transport (the default). :param ReceiveClientAsync handler: The handler. :rtype: None """ diff --git a/sdk/servicebus/azure-servicebus/pyproject.toml b/sdk/servicebus/azure-servicebus/pyproject.toml index 6c8b3024a9d5..4d1d9557b729 100644 --- a/sdk/servicebus/azure-servicebus/pyproject.toml +++ b/sdk/servicebus/azure-servicebus/pyproject.toml @@ -12,8 +12,7 @@ keywords = ["azure", "azure sdk"] requires-python = ">=3.9" license = "MIT" classifiers = [ - # TODO: Flip to "Development Status :: 5 - Production/Stable" when 7.15.0 ships as GA. - "Development Status :: 4 - Beta", + "Development Status :: 5 - Production/Stable", "Programming Language :: Python", "Programming Language :: Python :: 3 :: Only", "Programming Language :: Python :: 3",