-
Notifications
You must be signed in to change notification settings - Fork 2k
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.
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
Service bus : Amqp Types SEQUENCE and VALUE #20285
Service bus : Amqp Types SEQUENCE and VALUE #20285
Conversation
case VALUE: | ||
throw new RuntimeException("Body type not supported yet."); | ||
amqpValue = amqpAnnotatedMessage.getBody().getValue(); | ||
System.out.println(amqpValue); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
remove this line?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
It is fine because we are outputting the value in same , so user can see it.
...amqp/src/samples/java/com/azure/core/amqp/models/AmqpAnnotatedMessageJavaDocCodeSamples.java
Outdated
Show resolved
Hide resolved
} else if (body instanceof AmqpValue) { | ||
amqpMessageBody = AmqpMessageBody.fromValue(((AmqpValue)body).getValue()); | ||
} else if (body instanceof AmqpSequence) { | ||
List messageData = ((AmqpSequence) body).getValue(); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Use the generic notation when using List
.
sdk/core/azure-core-amqp/src/main/java/com/azure/core/amqp/models/AmqpMessageBody.java
Outdated
Show resolved
Hide resolved
sdk/core/azure-core-amqp/src/main/java/com/azure/core/amqp/models/AmqpMessageBody.java
Outdated
Show resolved
Hide resolved
sdk/core/azure-core-amqp/src/main/java/com/azure/core/amqp/models/AmqpMessageBody.java
Outdated
Show resolved
Hide resolved
sdk/core/azure-core-amqp/src/main/java/com/azure/core/amqp/models/AmqpMessageBody.java
Outdated
Show resolved
Hide resolved
sdk/core/azure-core-amqp/src/main/java/com/azure/core/amqp/models/AmqpMessageBody.java
Outdated
Show resolved
Hide resolved
sdk/core/azure-core-amqp/src/main/java/com/azure/core/amqp/models/AmqpMessageBody.java
Outdated
Show resolved
Hide resolved
sdk/core/azure-core-amqp/src/main/java/com/azure/core/amqp/models/AmqpMessageBody.java
Outdated
Show resolved
Hide resolved
...ure-messaging-servicebus/src/main/java/com/azure/messaging/servicebus/ServiceBusMessage.java
Outdated
Show resolved
Hide resolved
...ing-servicebus/src/main/java/com/azure/messaging/servicebus/ServiceBusMessageSerializer.java
Outdated
Show resolved
Hide resolved
a3ec7ae
into
Azure:feature/servicebus-support-amqp-data-types-17614
* Service bus adding max auto lock renew duration in processor client (#20317) * Added API in builder for "adding max auto lock renew duration in processor client" * Service Bus - Merging previously approved -cross transaction feature - into feature branch - preparation for April release. (#20356) * ServiceBus - cross entity transaction feature (#19863) New Feature: Cross entity transaction API * Service bus : Amqp Types SEQUENCE and VALUE (#20285) * Adding feature AMQP SEQUENCE/VALUE data type implementation * Merge master into branch * beta version change * getting ready to release beta * Updating beta version for event hubs * Fixing unit test case * Removing unwanted import * Fixing test subscriber name (#20666) Co-authored-by: hemanttanwar <hetanwar@users.noreply.github.com> * SB april beta release updates (#20672) * SB april beta release updates * Increment package version after release of com.azure azure-messaging-servicebus (#20690) * Use multiple subscribers for `maxConcurrentCalls` in ServiceBusProcessorClient (#21085) * Merge feature branch into release branch * Updated core-amqp version to release as beta
…22426) * Service bus adding max auto lock renew duration in processor client (#20317) * Added API in builder for "adding max auto lock renew duration in processor client" * Service Bus - Merging previously approved -cross transaction feature - into feature branch - preparation for April release. (#20356) * ServiceBus - cross entity transaction feature (#19863) New Feature: Cross entity transaction API * Service bus : Amqp Types SEQUENCE and VALUE (#20285) * Adding feature AMQP SEQUENCE/VALUE data type implementation * added subQueue API
Review request for Microsoft.ContainerService to add version 2022-07-01 (Azure#20285) * Adds base for updating Microsoft.ContainerService from version stable/2022-06-01 to version 2022-07-01 * Updates readme * Updates API version in new specs and examples * update readmes (Azure#19871) * Add example of Azure KeyVault Secrets Provider Addon for 2022-07-01 (Azure#19875) * add example of kv secret provider addon * fix lint * AKS OSSKU supports Windows options (Azure#19976) * OSSKU supports Windows options * Improve description * add default for availableAgentPoolVersions (Azure#19901) * sync PR Azure#19592 ARM ID annotations for ContainerService * separate examples for list cluster credentials operations Co-authored-by: Shiqian Tao <62196586+ShiqianTao@users.noreply.github.com>
Support following Amqp Types
Amqp supports following types and track 2 SDK also need to provide support for these types.
SEQUENCE http://docs.oasis-open.org/amqp/core/v1.0/amqp-core-messaging-v1.0.html#type-amqp-sequence
VALUE http://docs.oasis-open.org/amqp/core/v1.0/os/amqp-core-messaging-v1.0-os.html#type-amqp-value
Linked: #17614
API View : https://apiview.dev/Assemblies/Review/5a075817d7404a7381c0c139af985a40?diffRevisionId=0782a564a36343d6a7cf869f6be3a24c&doc=False&diffOnly=False