You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2024/03/22 06:03:56 UTC
(camel) 02/02: CAMEL-20596: Propagate Azure Service Bus message headers to/from Camel Message
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 0bc8f0b5a873db3168d5ba8a2ace15e24a09eabb
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Fri Mar 22 07:01:43 2024 +0100
CAMEL-20596: Propagate Azure Service Bus message headers to/from Camel Message
---
.../apache/camel/component/azure/servicebus/ServiceBusProducer.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/components/camel-azure/camel-azure-servicebus/src/main/java/org/apache/camel/component/azure/servicebus/ServiceBusProducer.java b/components/camel-azure/camel-azure-servicebus/src/main/java/org/apache/camel/component/azure/servicebus/ServiceBusProducer.java
index af387c3d22e..f13ff00abbf 100644
--- a/components/camel-azure/camel-azure-servicebus/src/main/java/org/apache/camel/component/azure/servicebus/ServiceBusProducer.java
+++ b/components/camel-azure/camel-azure-servicebus/src/main/java/org/apache/camel/component/azure/servicebus/ServiceBusProducer.java
@@ -148,7 +148,7 @@ public class ServiceBusProducer extends DefaultAsyncProducer {
return (exchange, callback) -> {
final Object inputBody = exchange.getMessage().getBody();
Map<String, Object> applicationProperties
- = exchange.getMessage().getHeader(ServiceBusConstants.APPLICATION_PROPERTIES, Map.class);
+ = exchange.getMessage().getHeader(ServiceBusConstants.APPLICATION_PROPERTIES, Map.class);
if (applicationProperties == null) {
applicationProperties = new HashMap<>();
}
@@ -182,7 +182,7 @@ public class ServiceBusProducer extends DefaultAsyncProducer {
return (exchange, callback) -> {
final Object inputBody = exchange.getMessage().getBody();
Map<String, Object> applicationProperties
- = exchange.getMessage().getHeader(ServiceBusConstants.APPLICATION_PROPERTIES, Map.class);
+ = exchange.getMessage().getHeader(ServiceBusConstants.APPLICATION_PROPERTIES, Map.class);
if (applicationProperties == null) {
applicationProperties = new HashMap<>();
}