Skip to content
New issue

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

#

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

Already on GitHub? # to your account

[CAMEL-18276] : azure-service-bus component support for session enabled entities #16826

Merged
merged 10 commits into from
Jan 16, 2025
Merged

[CAMEL-18276] : azure-service-bus component support for session enabled entities #16826

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
10 commits
Select commit Hold shift + click to select a range
c889f07
Camel ASB: sessionId support added for component and producer
Jan 12, 2025
e145bac
Camel ASB: test case updated for send operation with sessions
Jan 12, 2025
fe3a950
Camel ASB: enabled sessions for consumer for topic
Jan 12, 2025
f7a8ec1
Camel ASB: formatting done as per checkProfile plugin
Jan 12, 2025
f83cf1b
Camel ASB: producer IT test fixed with session processor
Jan 12, 2025
d30e62d
Camel ASB: producer IT test cases updated for queues and scheduled me…
Jan 14, 2025
984802e
Camel ASB: consumerIT cases updated for queues
Jan 14, 2025
ac1ccd5
Camel ASB: consumerIT cases updated for verifying order for session e…
Jan 14, 2025
4d8c2ca
Camel ASB: countdown latch timeout updated for added IT cases
Jan 15, 2025
c10ab5c
Camel ASB: documentation updated for session support
Jan 15, 2025
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
12 changes: 12 additions & 0 deletions ...rated/java/org/apache/camel/component/azure/servicebus/ServiceBusComponentConfigurer.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -76,6 +76,10 @@ public boolean configure(CamelContext camelContext, Object obj, String name, Obj
case "serviceBusTransactionContext": getOrCreateConfiguration(target).setServiceBusTransactionContext(property(camelContext, com.azure.messaging.servicebus.ServiceBusTransactionContext.class, value)); return true;
case "servicebustype":
case "serviceBusType": getOrCreateConfiguration(target).setServiceBusType(property(camelContext, org.apache.camel.component.azure.servicebus.ServiceBusType.class, value)); return true;
case "sessionenabled":
case "sessionEnabled": getOrCreateConfiguration(target).setSessionEnabled(property(camelContext, boolean.class, value)); return true;
case "sessionid":
case "sessionId": getOrCreateConfiguration(target).setSessionId(property(camelContext, java.lang.String.class, value)); return true;
case "subqueue":
case "subQueue": getOrCreateConfiguration(target).setSubQueue(property(camelContext, com.azure.messaging.servicebus.models.SubQueue.class, value)); return true;
case "subscriptionname":
Expand Down Expand Up @@ -140,6 +144,10 @@ public Class<?> getOptionType(String name, boolean ignoreCase) {
case "serviceBusTransactionContext": return com.azure.messaging.servicebus.ServiceBusTransactionContext.class;
case "servicebustype":
case "serviceBusType": return org.apache.camel.component.azure.servicebus.ServiceBusType.class;
case "sessionenabled":
case "sessionEnabled": return boolean.class;
case "sessionid":
case "sessionId": return java.lang.String.class;
case "subqueue":
case "subQueue": return com.azure.messaging.servicebus.models.SubQueue.class;
case "subscriptionname":
Expand Down Expand Up @@ -200,6 +208,10 @@ public Object getOptionValue(Object obj, String name, boolean ignoreCase) {
case "serviceBusTransactionContext": return getOrCreateConfiguration(target).getServiceBusTransactionContext();
case "servicebustype":
case "serviceBusType": return getOrCreateConfiguration(target).getServiceBusType();
case "sessionenabled":
case "sessionEnabled": return getOrCreateConfiguration(target).isSessionEnabled();
case "sessionid":
case "sessionId": return getOrCreateConfiguration(target).getSessionId();
case "subqueue":
case "subQueue": return getOrCreateConfiguration(target).getSubQueue();
case "subscriptionname":
Expand Down
12 changes: 12 additions & 0 deletions ...erated/java/org/apache/camel/component/azure/servicebus/ServiceBusEndpointConfigurer.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -70,6 +70,10 @@ public boolean configure(CamelContext camelContext, Object obj, String name, Obj
case "serviceBusTransactionContext": target.getConfiguration().setServiceBusTransactionContext(property(camelContext, com.azure.messaging.servicebus.ServiceBusTransactionContext.class, value)); return true;
case "servicebustype":
case "serviceBusType": target.getConfiguration().setServiceBusType(property(camelContext, org.apache.camel.component.azure.servicebus.ServiceBusType.class, value)); return true;
case "sessionenabled":
case "sessionEnabled": target.getConfiguration().setSessionEnabled(property(camelContext, boolean.class, value)); return true;
case "sessionid":
case "sessionId": target.getConfiguration().setSessionId(property(camelContext, java.lang.String.class, value)); return true;
case "subqueue":
case "subQueue": target.getConfiguration().setSubQueue(property(camelContext, com.azure.messaging.servicebus.models.SubQueue.class, value)); return true;
case "subscriptionname":
Expand Down Expand Up @@ -135,6 +139,10 @@ public Class<?> getOptionType(String name, boolean ignoreCase) {
case "serviceBusTransactionContext": return com.azure.messaging.servicebus.ServiceBusTransactionContext.class;
case "servicebustype":
case "serviceBusType": return org.apache.camel.component.azure.servicebus.ServiceBusType.class;
case "sessionenabled":
case "sessionEnabled": return boolean.class;
case "sessionid":
case "sessionId": return java.lang.String.class;
case "subqueue":
case "subQueue": return com.azure.messaging.servicebus.models.SubQueue.class;
case "subscriptionname":
Expand Down Expand Up @@ -196,6 +204,10 @@ public Object getOptionValue(Object obj, String name, boolean ignoreCase) {
case "serviceBusTransactionContext": return target.getConfiguration().getServiceBusTransactionContext();
case "servicebustype":
case "serviceBusType": return target.getConfiguration().getServiceBusType();
case "sessionenabled":
case "sessionEnabled": return target.getConfiguration().isSessionEnabled();
case "sessionid":
case "sessionId": return target.getConfiguration().getSessionId();
case "subqueue":
case "subQueue": return target.getConfiguration().getSubQueue();
case "subscriptionname":
Expand Down
4 changes: 3 additions & 1 deletion ...erated/java/org/apache/camel/component/azure/servicebus/ServiceBusEndpointUriFactory.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@ public class ServiceBusEndpointUriFactory extends org.apache.camel.support.compo
private static final Set<String> SECRET_PROPERTY_NAMES;
private static final Set<String> MULTI_VALUE_PREFIXES;
static {
Set<String> props = new HashSet<>(28);
Set<String> props = new HashSet<>(30);
props.add("amqpRetryOptions");
props.add("amqpTransportType");
props.add("binary");
Expand All @@ -48,6 +48,8 @@ public class ServiceBusEndpointUriFactory extends org.apache.camel.support.compo
props.add("serviceBusReceiveMode");
props.add("serviceBusTransactionContext");
props.add("serviceBusType");
props.add("sessionEnabled");
props.add("sessionId");
props.add("subQueue");
props.add("subscriptionName");
props.add("tokenCredential");
Expand Down
Loading
Loading