Skip to content
Draft
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
21 changes: 7 additions & 14 deletions sdk/servicebus/azure-servicebus/CHANGELOG.md
Original file line number Diff line number Diff line change
@@ -1,11 +1,16 @@
# Release History

## 7.15.0b3 (Unreleased)
## 7.15.0 (2026-10-06)
Comment thread
EldertGrootenboer marked this conversation as resolved.

### 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`.
Expand All @@ -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))
Expand All @@ -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)

Expand Down
2 changes: 1 addition & 1 deletion sdk/servicebus/azure-servicebus/api.metadata.yml
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
apiMdSha256: a5f9da8d7980799f054d782f99eabf9b190925718f2bc4bdd86f01752a5c1bf8
packageVersion: 7.15.0b3
packageVersion: 7.15.0
parserVersion: 0.3.31
pythonVersion: 3.14.0
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down Expand Up @@ -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

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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
"""
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -3,4 +3,4 @@
# Licensed under the MIT License.
# ------------------------------------

VERSION = "7.15.0b3"
VERSION = "7.15.0"
Comment thread
EldertGrootenboer marked this conversation as resolved.
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down Expand Up @@ -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

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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
"""
Expand Down
3 changes: 1 addition & 2 deletions sdk/servicebus/azure-servicebus/pyproject.toml
Original file line number Diff line number Diff line change
Expand Up @@ -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",
Expand Down