Francesco Spampinato created CAMEL-23895:
--------------------------------------------
Summary: [camel-azure-servicebus] http 401 using connection string
Key: CAMEL-23895
URL: https://issues.apache.org/jira/browse/CAMEL-23895
Project: Camel
Issue Type: Bug
Components: camel-azure-servicebus
Affects Versions: 4.21.0
Reporter: Francesco Spampinato
Hi,
if a create an azure service bus queue consumer in this way
{code:java}
from(azureServicebus("MyQueue")
.connectionString("MyConnectionString"))
.routeId("consumer")
.log(LoggingLevel.INFO, LOG, ">> body: ${body}")
.log(LoggingLevel.INFO, LOG, ">> header: ${headers}"); {code}
connection to service bus queue fails with this error
{code:java}
Caused by: com.azure.core.amqp.exception.AmqpException: status-code: 401,
status-description: InvalidSignature: The token has an invalid signature.,
{code}
Using same queue name and same connection string using plain azure sdk lib
classes, connection is ok and i can consume messages without errors
{code:java}
ServiceBusProcessorClient processorClient = new ServiceBusClientBuilder()
.connectionString("MyConnectionString")
.processor()
.queueName("MyQueue")
.processMessage(Test::processMessage)
.processError(Test::processError)
.buildProcessorClient(); {code}
azure sdk is the same in the two projects
{code:java}
<dependency>
<groupId>com.azure</groupId>
<artifactId>azure-messaging-servicebus</artifactId>
<version>7.17.16</version>
</dependency>{code}
The connection string used is in this format
{color:#cccccc}{color:#17c6a3}Endpoint=sb://myhost.servicebus.windows.net/;SharedAccessKeyName=test;SharedAccessKey=XXXXXXXXXXXXXXXXX{color}{color}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
