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
>
