Messaging: v2 stack amqp-core types and integration to Service Bus #34854
Conversation
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
|
API change check APIView has identified API level changes in this PR and created following API reviews. |
conniey
reviewed
May 9, 2023
sdk/core/azure-core-amqp/src/main/java/com/azure/core/amqp/implementation/CreditAccounting.java
Outdated
Show resolved
Hide resolved
conniey
reviewed
May 9, 2023
...re-amqp/src/main/java/com/azure/core/amqp/implementation/EmissionDrivenCreditAccounting.java
Outdated
Show resolved
Hide resolved
conniey
reviewed
May 9, 2023
...re-amqp/src/main/java/com/azure/core/amqp/implementation/EmissionDrivenCreditAccounting.java
Outdated
Show resolved
Hide resolved
conniey
reviewed
May 9, 2023
sdk/core/azure-core-amqp/src/main/java/com/azure/core/amqp/implementation/MessageFlux.java
Show resolved
Hide resolved
conniey
reviewed
May 9, 2023
sdk/core/azure-core-amqp/src/main/java/com/azure/core/amqp/implementation/MessageFlux.java
Outdated
Show resolved
Hide resolved
sdk/core/azure-core-amqp/src/main/java/com/azure/core/amqp/implementation/MessageFlux.java
Outdated
Show resolved
Hide resolved
sdk/core/azure-core-amqp/src/main/java/com/azure/core/amqp/implementation/MessageFlux.java
Outdated
Show resolved
Hide resolved
sdk/core/azure-core-amqp/src/main/java/com/azure/core/amqp/implementation/MessageFlux.java
Show resolved
Hide resolved
4a6ff46 to
00f008d
Compare
lmolkova
reviewed
May 11, 2023
...ervicebus/src/main/java/com/azure/messaging/servicebus/implementation/ManagementChannel.java
Outdated
Show resolved
Hide resolved
...s/src/main/java/com/azure/messaging/servicebus/implementation/ServiceBusReactorReceiver.java
Show resolved
Hide resolved
...s/src/main/java/com/azure/messaging/servicebus/implementation/ServiceBusReactorReceiver.java
Show resolved
Hide resolved
...s/src/main/java/com/azure/messaging/servicebus/implementation/ServiceBusReactorReceiver.java
Outdated
Show resolved
Hide resolved
...s/src/main/java/com/azure/messaging/servicebus/implementation/ServiceBusReactorReceiver.java
Outdated
Show resolved
Hide resolved
sdk/core/azure-core-amqp/src/main/java/com/azure/core/amqp/implementation/MessageFlux.java
Show resolved
Hide resolved
sdk/core/azure-core-amqp/src/main/java/com/azure/core/amqp/implementation/MessageFlux.java
Show resolved
Hide resolved
sdk/core/azure-core-amqp/src/main/java/com/azure/core/amqp/implementation/ReactorReceiver.java
Outdated
Show resolved
Hide resolved
...-core-amqp/src/main/java/com/azure/core/amqp/implementation/handler/ReceiveLinkHandler2.java
Outdated
Show resolved
Hide resolved
...e-amqp/src/main/java/com/azure/core/amqp/implementation/handler/ReceiverDeliveryHandler.java
Outdated
Show resolved
Hide resolved
1557f7d to
917f037
Compare
72b45b7 to
84266cb
Compare
This was referenced Jun 7, 2023
Closed
Closed
Closed
Closed
aa0f02b to
6b83851
Compare
6b83851 to
e0a55ef
Compare
…n in Isolated mode.
…nRetriesOnRejectedOutcome test
…g invocation.getArgument to access the creditSupplier, which removes the need for casting
…tFlowMode and Prefetch arguments for tests.
… createShutdownSignal()
… the meter only once to see if sequence number tracking is needed, improve logic in beginClose(ErrorCondition) by chaining localCloseMono inline instead of passing localCloseMono to wrapper, moving comment about wrapper in Receiver to Javadoc of ReceiveLinkHandlerWrapper.
…s Flux and instead let subscribe to handle the signals (active, error and completion)
…edit in v1 code path.
…solatedTest: Using methodSource to choose the stack on which tests to run. define retryOptions in test as static.
…() operator, so one less operator in the chain.
…se of this., ServiceBusSingleSessionManager: Removing JavaDoc unsupported self closing paragraph.
…ead of untyped CsvSource.
… ReentrantLock. The updateAndGet is allowed to invoke the compute function more than once under the race. The ReentrantLock adds no overhead here since logic in the block is side-effect free.
…ize equal to max-link-size) for tracking the overall size of messages in the batch.
91b65a8 to
efd3d99
Compare
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
No description provided.