diff --git a/sdk/servicebus/azure-servicebus/CHANGELOG.md b/sdk/servicebus/azure-servicebus/CHANGELOG.md index 7fd922979528..3556002dbdab 100644 --- a/sdk/servicebus/azure-servicebus/CHANGELOG.md +++ b/sdk/servicebus/azure-servicebus/CHANGELOG.md @@ -9,7 +9,7 @@ * Added new properties to Message, PeekMessage and ReceivedMessage: `content_type`, `correlation_id`, `label`, `message_id`, `reply_to`, `reply_to_session_id` and `to`. Please refer to the docstring for further information. -* Added new properties to PeekedMessaged and ReceivedMessage: `enqueued_sequence_number`, `dead_letter_error_description`, +* Added new properties to PeekMessage and ReceivedMessage: `enqueued_sequence_number`, `dead_letter_error_description`, `dead_letter_reason`, `dead_letter_source`, `delivery_count` and `expires_at_utc`. Please refer to the docstring for further information. * Added support for sending received messages via `ServiceBusSender.send_messages`. * Added `on_lock_renew_failure` as a parameter to `AutoLockRenew.register`, taking a callback for when the lock is lost non-intentially (e.g. not via settling, shutdown, or autolockrenew duration completion). diff --git a/sdk/servicebus/azure-servicebus/samples/async_samples/session_pool_receive_async.py b/sdk/servicebus/azure-servicebus/samples/async_samples/session_pool_receive_async.py index 043e4ccf9a28..6315f7744d54 100644 --- a/sdk/servicebus/azure-servicebus/samples/async_samples/session_pool_receive_async.py +++ b/sdk/servicebus/azure-servicebus/samples/async_samples/session_pool_receive_async.py @@ -21,7 +21,7 @@ async def message_processing(servicebus_client, queue_name): while True: try: - async with servicebus_client.get_queue_session_receiver(queue_name, idle_timeout=1) as receiver: + async with servicebus_client.get_queue_session_receiver(queue_name, max_wait_time=1) as receiver: renewer = AutoLockRenew() renewer.register(receiver.session) await receiver.session.set_session_state("OPEN") @@ -38,7 +38,7 @@ async def message_processing(servicebus_client, queue_name): if str(message) == 'shutdown': await receiver.session.set_session_state("CLOSED") break - await renewer.shutdown() + await renewer.close() except NoActiveSession: print("There are no non-empty sessions remaining; exiting. This may present as a UserError in the azure portal.") return diff --git a/sdk/servicebus/azure-servicebus/samples/sync_samples/session_pool_receive.py b/sdk/servicebus/azure-servicebus/samples/sync_samples/session_pool_receive.py index 20fa57539e58..64f4beeef6ee 100644 --- a/sdk/servicebus/azure-servicebus/samples/sync_samples/session_pool_receive.py +++ b/sdk/servicebus/azure-servicebus/samples/sync_samples/session_pool_receive.py @@ -36,7 +36,7 @@ def message_processing(sb_client, queue_name, messages): message.complete() if str(message) == 'shutdown': receiver.session.set_session_state("CLOSED") - renewer.shutdown() + renewer.close() except NoActiveSession: print("There are no non-empty sessions remaining; exiting. This may present as a UserError in the azure portal.") return