[
https://issues.apache.org/jira/browse/CAMEL-20805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
JJ updated CAMEL-20805:
-----------------------
Description:
I have a connection to an Azure service bus queue defined in xml
{code:xml}
<route id="Elexon_IRIS_Route">
<from uri="azureQueueEndpoint" />
<convertBodyTo type="java.lang.String"/>
<unmarshal><json/></unmarshal>
<to uri="localAMQ:topic:IRIS-Elexon"/>
</route>
<bean id="azureServiceBusComponent"
class="org.apache.camel.component.azure.servicebus.ServiceBusComponent">
<property name="configuration">
<bean
class="org.apache.camel.component.azure.servicebus.ServiceBusConfiguration">
<property name="credentialType" value="TOKEN_CREDENTIAL" />
<property name="tokenCredential" ref="azauth" />
<property name="fullyQualifiedNamespace"
value="elexon-iris.servicebus.windows.net" />
</bean>
</property>
</bean>
{code}
Using camel-azure-servicebus-4.4.1 I get the following headers returned for
each message:
{code:java}
{"expires"=>"0", "CamelAzureServiceBusEnqueuedSequenceNumber"=>"10655170",
"destination"=>"/topic/IRIS-Elexon", "CamelAzureServiceBusDeliveryCount"=>"0",
"ack"=>"ID:bravo-43103-1716763678894-2:59",
"CamelAzureServiceBusSubject"=>"MELS",
"subscription"=>"4b0062c6-48be-4cb2-abce85d1481b3401", "priority"=>"4",
"CamelAzureServiceBusSequenceNumber"=>"7955951",
"CamelAzureServiceBusMessageId"=>"MELS_202405262248_85602.json",
"message-id"=>"ID:bravo-43103-1716763678894-10:1:3:1:1272",
"persistent"=>"true", "timestamp"=>"1716763744004",
"CamelAzureServiceBusLockToken"=>"64179600-27db-48ed-be93-eb19ebe0f66b"}{code}
But when I change to camel-azure-servicebus-4.4.2 the only headers I get are:
{code:java}
{"expires"=>"0", "destination"=>"/topic/IRIS-Elexon",
"ack"=>"ID:bravo-34173-1716750388709-2:15634",
"subscription"=>"16b02d1f-40df-4f31-b538738618f91316", "priority"=>"4",
"message-id"=>"ID:bravo-34173-1716750388709-10:1:5:1:43221",
"persistent"=>"true", "source_file_name"=>"MELS_202405262245_85595.json",
"timestamp"=>"1716763562372"} {code}
How do I get the CamelAzureServiceBus headers back? I filter on those within a
processing script so this is a rather breaking change.
was:
I have a connection to an Azure service bus queue defined in xml
{{{code:xml}}}
<route id="Elexon_IRIS_Route">
<from uri="azureQueueEndpoint" />
<convertBodyTo type="java.lang.String"/>
<unmarshal><json/></unmarshal>
<to uri="localAMQ:topic:IRIS-Elexon"/>
</route>
<bean id="azureServiceBusComponent"
class="org.apache.camel.component.azure.servicebus.ServiceBusComponent">
<property name="configuration">
<bean
class="org.apache.camel.component.azure.servicebus.ServiceBusConfiguration">
<property name="credentialType" value="TOKEN_CREDENTIAL" />
<property name="tokenCredential" ref="azauth" />
<property name="fullyQualifiedNamespace"
value="elexon-iris.servicebus.windows.net" />
</bean>
</property>
</bean>
{{{code}}}
Using camel-azure-servicebus-4.4.1 I get the following headers returned for
each message:
{"expires"=>"0", "CamelAzureServiceBusEnqueuedSequenceNumber"=>"10655170",
"destination"=>"/topic/IRIS-Elexon", "CamelAzureServiceBusDeliveryCount"=>"0",
"ack"=>"ID:bravo-43103-1716763678894-2:59",
"CamelAzureServiceBusSubject"=>"MELS",
"subscription"=>"4b0062c6-48be-4cb2-abce85d1481b3401", "priority"=>"4",
"CamelAzureServiceBusSequenceNumber"=>"7955951",
"CamelAzureServiceBusMessageId"=>"MELS_202405262248_85602.json",
"message-id"=>"ID:bravo-43103-1716763678894-10:1:3:1:1272",
"persistent"=>"true", "timestamp"=>"1716763744004",
"CamelAzureServiceBusLockToken"=>"64179600-27db-48ed-be93-eb19ebe0f66b"}
But when I change to camel-azure-servicebus-4.4.2 the only headers I get are:
{"expires"=>"0", "destination"=>"/topic/IRIS-Elexon",
"ack"=>"ID:bravo-34173-1716750388709-2:15634",
"subscription"=>"16b02d1f-40df-4f31-b538738618f91316", "priority"=>"4",
"message-id"=>"ID:bravo-34173-1716750388709-10:1:5:1:43221",
"persistent"=>"true", "source_file_name"=>"MELS_202405262245_85595.json",
"timestamp"=>"1716763562372"}
How do I get the CamelAzureServiceBus headers back? I filter on those within a
processing script so this is a rather breaking change.
> CamelAzureServiceBus headers missing since upgrading to
> camel-azure-servicebus-4.4.2
> ------------------------------------------------------------------------------------
>
> Key: CAMEL-20805
> URL: https://issues.apache.org/jira/browse/CAMEL-20805
> Project: Camel
> Issue Type: Bug
> Components: camel-azure
> Affects Versions: 4.4.2
> Environment: Oracle EL8
> java-latest-openjdk-22.0.1.0.8-1.rolling.el8.x86_64
> Camel 4.4.2 Embedded in ActiveMQ 6.1.2
> Reporter: JJ
> Priority: Major
> Labels: help-wanted
>
> I have a connection to an Azure service bus queue defined in xml
> {code:xml}
> <route id="Elexon_IRIS_Route">
> <from uri="azureQueueEndpoint" />
> <convertBodyTo type="java.lang.String"/>
> <unmarshal><json/></unmarshal>
> <to uri="localAMQ:topic:IRIS-Elexon"/>
> </route>
> <bean id="azureServiceBusComponent"
> class="org.apache.camel.component.azure.servicebus.ServiceBusComponent">
> <property name="configuration">
> <bean
> class="org.apache.camel.component.azure.servicebus.ServiceBusConfiguration">
> <property name="credentialType" value="TOKEN_CREDENTIAL" />
> <property name="tokenCredential" ref="azauth" />
> <property name="fullyQualifiedNamespace"
> value="elexon-iris.servicebus.windows.net" />
> </bean>
> </property>
> </bean>
> {code}
> Using camel-azure-servicebus-4.4.1 I get the following headers returned for
> each message:
> {code:java}
> {"expires"=>"0", "CamelAzureServiceBusEnqueuedSequenceNumber"=>"10655170",
> "destination"=>"/topic/IRIS-Elexon",
> "CamelAzureServiceBusDeliveryCount"=>"0",
> "ack"=>"ID:bravo-43103-1716763678894-2:59",
> "CamelAzureServiceBusSubject"=>"MELS",
> "subscription"=>"4b0062c6-48be-4cb2-abce85d1481b3401", "priority"=>"4",
> "CamelAzureServiceBusSequenceNumber"=>"7955951",
> "CamelAzureServiceBusMessageId"=>"MELS_202405262248_85602.json",
> "message-id"=>"ID:bravo-43103-1716763678894-10:1:3:1:1272",
> "persistent"=>"true", "timestamp"=>"1716763744004",
> "CamelAzureServiceBusLockToken"=>"64179600-27db-48ed-be93-eb19ebe0f66b"}{code}
>
> But when I change to camel-azure-servicebus-4.4.2 the only headers I get are:
> {code:java}
> {"expires"=>"0", "destination"=>"/topic/IRIS-Elexon",
> "ack"=>"ID:bravo-34173-1716750388709-2:15634",
> "subscription"=>"16b02d1f-40df-4f31-b538738618f91316", "priority"=>"4",
> "message-id"=>"ID:bravo-34173-1716750388709-10:1:5:1:43221",
> "persistent"=>"true", "source_file_name"=>"MELS_202405262245_85595.json",
> "timestamp"=>"1716763562372"} {code}
> How do I get the CamelAzureServiceBus headers back? I filter on those within
> a processing script so this is a rather breaking change.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
