-
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
Modify for messaging apireview #26200
Modify for messaging apireview #26200
Conversation
…zure/azure-sdk-for-java into add-javadoc-for-integration
…zure/azure-sdk-for-java into add-javadoc-for-integration
…zure/azure-sdk-for-java into add-javadoc-for-integration
@@ -137,10 +136,10 @@ protected MessageProducer createConsumerEndpoint(ConsumerDestination destination | |||
buildCheckpointConfig(properties)); | |||
} | |||
inboundAdapter.setBeanFactory(getBeanFactory()); | |||
String instrumentationId = Instrumentation.buildId(CONSUMER, destination.getName() + "/" + (!INVALID_SUBSCRIPTION.equals(group) ? group : "")); | |||
String instrumentationId = Instrumentation.buildId(CONSUMER, destination.getName() + "/" + (!INVALID_GROUP.equals(group) ? group : "")); |
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.
Can we extract a private method for this (!INVALID_GROUP.equals(group) ? group : "")
...ain/java/com/azure/spring/cloud/stream/binder/servicebus/ServiceBusMessageChannelBinder.java
Show resolved
Hide resolved
/azp run java - sping - tests |
No pipelines are associated with this pull request. |
/azp run java - spring - tests |
...a/com/azure/spring/servicebus/core/processor/DefaultServiceBusNamespaceProcessorFactory.java
Outdated
Show resolved
Hide resolved
Azure Pipelines successfully started running 1 pipeline(s). |
@@ -137,10 +132,10 @@ protected MessageProducer createConsumerEndpoint(ConsumerDestination destination | |||
buildCheckpointConfig(properties)); |
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.
Seems like here we can adjust the ServiceBusInboundChannelAdapter constructor to always receives destination and group, and decide whether it's a queue internally?
/azp run java - spring - tests |
Azure Pipelines successfully started running 1 pipeline(s). |
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.
LGTM.
[TypeSpec] Upgrade to 0.49.0 (Azure#26200)
Update spring-messaging-azure-* libraries according to api-review results.
Ref:
spring-messaging-azure-servicebus: https://apiview.dev/Assemblies/Review/72aca2ba5bd7413aabc8cbe99e06acf4
spring-messaging-azure-eventhubs: https://apiview.dev/Assemblies/Review/58995c5facde49aa8898510ae955d5b6#
spring-messaging-azure-storage-queue: https://apiview.dev/Assemblies/Review/fba59870bb51473db28b423394a1a75a