Hi, Thanks for the reply. I think I registered it correctly using this:
*camelContext.getRegistry().bind("producerAsyncClient",eventHubProducerAsyncClient);* I'm not sure what I'm missing if I look at the link you shared. Before I was using a seperate bean to produce this factory using a @ApplicationScoped class containing a method annotated with @Produces that returns the EventHubProducerAsyncClient. On Tue, Jun 6, 2023 at 8:14 AM Zineb Bendhiba <bendhiba.zi...@gmail.com> wrote: > Hello, > > How did you register the bean named `producerAsyncClient` ? > > FYI, this is one example of registering the beans in a Quarkus application > : > > https://github.com/apache/camel-quarkus/blob/da04acd1cfd167219d54ea31aaea0c24585fc094/integration-tests/hl7/src/main/java/org/apache/camel/quarkus/component/hl7/it/Hl7Producers.java#L38 > < > https://github.com/apache/camel-quarkus/blob/da04acd1cfd167219d54ea31aaea0c24585fc094/integration-tests/hl7/src/main/java/org/apache/camel/quarkus/component/hl7/it/Hl7Producers.java#L38 > > > > > > Le lun. 5 juin 2023 à 21:56, Brian <brian.hesselm...@gmail.com> a écrit : > > > Hi, > > > > Does anyone have experience using the producerAsyncClient in camel > > eventhubs? I've been trying to implement this producer instead of using > > connectionstring directly in the camel uri. > > > > My uri looks like this: > > > > > > > "azure-eventhubs:mynamespace/myeventhub?producerAsyncClient=#producerAsyncClient" > > > > (I also tried using it without mynamespace/myeventhub with the same > result) > > and the code for the producer like this: > > > > < > > > https://camel.zulipchat.com/#narrow/stream/257302-camel-quarkus/topic/problem.20using.20eventhubs.20extension.20with.20producerAsyncClient/near/363754808 > > > > > > > private static final String SERVICE_URI_POSTFIX = " > servicebus.windows.net > > "; > > > > EventHubProducerAsyncClient eventHubProducerAsyncClient = new > > EventHubClientBuilder() > > .credential(getCredential()) > > > .fullyQualifiedNamespace(eventhubProperties.eventhubNameSpace() > > + "." + SERVICE_URI_POSTFIX) > > .eventHubName(eventhubProperties.eventhubName()) > > .buildAsyncProducerClient(); > > context.getRegistry().bind("producerAsyncClient", > > eventHubProducerAsyncClient); > > > > private ClientSecretCredential getCredential() { > > return new ClientSecretCredentialBuilder() > > .clientId(eventhubProperties.azureClientId()) > > .clientSecret(eventhubProperties.azureClientSecret()) > > .tenantId(eventhubProperties.azureTenantId()) > > .build(); > > } > > > > But the problem I face is that when sending a message it returns this > > error: > > > > 2023-06-05 15:35:28,067 ERROR [rea.cor.pub.Operators] > > (reactor-executor-4) Operator called default onErrorDropped: > > reactor.core.Exceptions$ErrorCallbackNotImplemented: > > com.azure.core.amqp.exception.AmqpException: errorContext[NAMESPACE: > > null.servicebus.windows.net. ERROR CONTEXT: N/A] > > Caused by: com.azure.core.amqp.exception.AmqpException: > > errorContext[NAMESPACE: null.servicebus.windows.net. ERROR CONTEXT: > > N/A] > > > > It seems the namespace is null when sending. > > > > > -- > Zineb >