Skip to content

Add ServiceBusProcessorAsyncClient (async message processor) (#46564) #49851

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Draft
EldertGrootenboer wants to merge 16 commits into
base: main
Choose a base branch
from
Draft

Add ServiceBusProcessorAsyncClient (async message processor) (#46564) #49851

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
16 commits
Select commit Hold shift + click to select a range
c7c23bd
feat: Add ServiceBusProcessorAsyncClient async message processor
EldertGrootenboer Jul 17, 2026
738fd1d
Merge branch 'main' into feature/servicebus-processor-async-client-46564
EldertGrootenboer Jul 17, 2026
75434de
fix: Address PR review feedback on ServiceBusProcessorAsyncClient
EldertGrootenboer Jul 17, 2026
084c098
fix: Address second-round PR review feedback
EldertGrootenboer Jul 17, 2026
e9a8da0
fix: Fast-path skip during drain to avoid counter churn
EldertGrootenboer Jul 17, 2026
ae93888
fix: Resolve javadoc build failure and address review comments
EldertGrootenboer Jul 17, 2026
c44bcce
fix: Only auto-settle PEEK_LOCK messages (not RECEIVE_AND_DELETE)
EldertGrootenboer Jul 17, 2026
43ca463
docs: Clarify processMessage concurrency in async builder javadoc
EldertGrootenboer Jul 17, 2026
b519755
docs: Wrap long javadoc line and hyphenate non-session-enabled
EldertGrootenboer Jul 17, 2026
5748682
docs: Clarify session maxConcurrentCalls is a total, not per-session,…
EldertGrootenboer Jul 17, 2026
b4ee108
docs: Document RECEIVE_AND_DELETE shutdown limitation on close()
EldertGrootenboer Jul 17, 2026
08f56d2
fix: Schedule receiver restart off the reactive receive thread
EldertGrootenboer Jul 17, 2026
21289de
fix: Balance handler count on synchronous dispatch failure
EldertGrootenboer Jul 17, 2026
205980b
test: Make error-callback assertions discriminating
EldertGrootenboer Jul 17, 2026
890f79a
docs: Hyphenate non-session-enabled in async processor builder javadoc
EldertGrootenboer Jul 17, 2026
283d493
docs: Clarify stop() cancels in-flight handlers, close() drains
EldertGrootenboer Jul 17, 2026
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
6 changes: 6 additions & 0 deletions sdk/servicebus/azure-messaging-servicebus/CHANGELOG.md
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -4,6 +4,12 @@

### Features Added

- Added `ServiceBusProcessorAsyncClient`, an asynchronous processor whose message and error handlers return a
`reactor.core.publisher.Mono` instead of running as blocking `Consumer` callbacks. It provides the same
push-based, auto-recovering, concurrency-managed message pump as `ServiceBusProcessorClient` for applications that
perform I/O-bound work reactively in the handler. Build it via `ServiceBusClientBuilder.processorAsync()` and
`ServiceBusClientBuilder.sessionProcessorAsync()`. ([#46564](https://github.com/Azure/azure-sdk-for-java/issues/46564))

### Breaking Changes

### Bugs Fixed
Expand Down
Loading
Loading