Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

java.lang.IllegalStateException: The stream has no active subscriptions smallrye-reactive-messaging-camel #3474

Closed
freedev opened this issue Jan 19, 2022 · 6 comments
Closed

java.lang.IllegalStateException: The stream has no active subscriptions smallrye-reactive-messaging-camel #3474

freedev opened this issue Jan 19, 2022 · 6 comments

Comments

@freedev
Copy link

freedev commented Jan 19, 2022 •
edited

I encoundered this issue with a simple project, I commited the source here:
https://github.com/freedev/code-with-quarkus-camel

mp.messaging.incoming.source-in.connector=smallrye-camel
mp.messaging.incoming.source-in.endpoint-uri=azure-servicebus:my-topic?subscriptionName=my-topic-subscription&amqpTransportType=AmqpWebSockets&serviceBusType=topic&connectionString=Endpoint=sb://my-azuresb.servicebus.windows.net/;SharedAccessKeyName=camelTest;SharedAccessKey=XXXXXX;EntityPath=my-topic

    @Incoming("source-in")
    public CompletionStage<Void> consume(Message<String> message) {
        System.out.println(message);
        return message.ack();
    }

At first run, quarkus tryes to read from the azure sb topic but an exception is raised

/Users/freedev/.sdkman/candidates/java/17.0.1-tem/bin/java -Dmaven.multiModuleProjectDirectory=/Users/freedev -Dmaven.home=/Users/freedev/.m2/wrapper/dists/apache-maven-3.8.4-bin/52ccbt68d252mdldqsfsn03jlf/apache-maven-3.8.4 -Dclassworlds.conf=/Users/freedev/.m2/wrapper/dists/apache-maven-3.8.4-bin/52ccbt68d252mdldqsfsn03jlf/apache-maven-3.8.4/bin/m2.conf -Dfile.encoding=UTF-8 -classpath /Users/freedev/.m2/wrapper/dists/apache-maven-3.8.4-bin/52ccbt68d252mdldqsfsn03jlf/apache-maven-3.8.4/boot/plexus-classworlds.license:/Users/freedev/.m2/wrapper/dists/apache-maven-3.8.4-bin/52ccbt68d252mdldqsfsn03jlf/apache-maven-3.8.4/boot/plexus-classworlds-2.6.0.jar org.codehaus.classworlds.Launcher -Didea.version=2021.3.1 -Ddebug=64713 quarkus:dev
[INFO] Scanning for projects...
[INFO] 
[INFO] ------------< t.lux.quarkus.azure:code-with-quarkus-camel >-------------
[INFO] Building code-with-quarkus-camel 1.0.0-SNAPSHOT
[INFO] --------------------------------[ jar ]---------------------------------
[INFO] 
[INFO] --- quarkus-maven-plugin:2.6.2.Final:dev (default-cli) @ code-with-quarkus-camel ---
[INFO] Invoking org.apache.maven.plugins:maven-resources-plugin:2.6:resources) @ code-with-quarkus-camel
[INFO] Using 'UTF-8' encoding to copy filtered resources.
[INFO] Copying 1 resource
[INFO] Invoking io.quarkus.platform:quarkus-maven-plugin:2.6.2.Final:generate-code) @ code-with-quarkus-camel
[INFO] Invoking org.apache.maven.plugins:maven-compiler-plugin:3.8.1:compile) @ code-with-quarkus-camel
[INFO] Nothing to compile - all classes are up to date
[INFO] Invoking org.apache.maven.plugins:maven-resources-plugin:2.6:testResources) @ code-with-quarkus-camel
[INFO] Using 'UTF-8' encoding to copy filtered resources.
[INFO] skip non existing resourceDirectory /Users/freedev/git/personal/quarkus/code-with-quarkus-camel/src/test/resources
[INFO] Invoking io.quarkus.platform:quarkus-maven-plugin:2.6.2.Final:generate-code-tests) @ code-with-quarkus-camel
[INFO] Invoking org.apache.maven.plugins:maven-compiler-plugin:3.8.1:testCompile) @ code-with-quarkus-camel
[INFO] Nothing to compile - all classes are up to date
Listening for transport dt_socket at address: 64713
Connected to the target VM, address: '127.0.0.1:64713', transport: 'socket'
Press [h] for more options>
Tests paused
Press [r] to resume testing, [h] for more options>
Press [r] to resume testing, [o] Toggle test output, [h] for more options>
2022-01-19 23:58:40,134 INFO  [io.qua.arc.pro.BeanProcessor] (build-21) Found unrecommended usage of private members (use package-private instead) in application beans:
	- @Inject field t.lux.quarkus.azure.MyReactiveMessagingApplication#camelContext
__  ____  __  _____   ___  __ ____  ______ 
 --/ __ \/ / / / _ | / _ \/ //_/ / / / __/ 
 -/ /_/ / /_/ / __ |/ , _/ ,< / /_/ /\ \   
--\___\_\____/_/ |_/_/|_/_/|_|\____/___/   
2022-01-19 23:58:40,506 INFO  [io.sma.rea.mes.camel] (Quarkus Main Thread) SRMSG17801: Creating publisher from Camel endpoint azure-servicebus:source-in?subscriptionName=source-in-subscription&amqpTransportType=AmqpWebSockets&serviceBusType=topic&connectionString=Endpoint=sb://my-azuresb.servicebus.windows.net/;SharedAccessKeyName=camelTest;SharedAccessKey=XXXXXXXX=;EntityPath=source-in
2022-01-19 23:58:40,802 INFO  [com.azu.mes.ser.ServiceBusClientBuilder] (Quarkus Main Thread) Setting 'entityName' [source-in] from connectionString.
2022-01-19 23:58:40,931 INFO  [com.azu.mes.ser.imp.ServiceBusConnectionProcessor] (Quarkus Main Thread) namespace[my-azuresb.servicebus.windows.net] entityPath[N/A]: Setting next AMQP channel.
2022-01-19 23:58:40,931 INFO  [com.azu.mes.ser.imp.ServiceBusConnectionProcessor] (Quarkus Main Thread) namespace[my-azuresb.servicebus.windows.net] entityPath[N/A]: Next AMQP channel received, updating 0 current subscribers
2022-01-19 23:58:40,933 INFO  [com.azu.mes.ser.ServiceBusClientBuilder] (Quarkus Main Thread) # of open clients with shared connection: 1
2022-01-19 23:58:40,942 INFO  [com.azu.mes.ser.ServiceBusReceiverAsyncClient] (Quarkus Main Thread) source-in/subscriptions/source-in-subscription: Creating consumer for link 'source-in/subscriptions/source-in-subscription_74188f_1642633120942'
2022-01-19 23:58:40,947 INFO  [com.azu.mes.ser.imp.ServiceBusReceiveLinkProcessor] (Quarkus Main Thread) Requesting a new AmqpReceiveLink from upstream.
2022-01-19 23:58:40,957 INFO  [com.azu.cor.amq.imp.ReactorConnection] (Quarkus Main Thread) connectionId[MF_167a3f_1642633120898]: Creating and starting connection to my-azuresb.servicebus.windows.net:443
2022-01-19 23:58:40,975 INFO  [com.azu.cor.amq.imp.ReactorExecutor] (Quarkus Main Thread) connectionId[MF_167a3f_1642633120898] message[Starting reactor.]
2022-01-19 23:58:40,981 INFO  [com.azu.cor.amq.imp.han.ConnectionHandler] (reactor-executor-1) onConnectionInit connectionId[MF_167a3f_1642633120898] hostname[my-azuresb.servicebus.windows.net] amqpHostname[my-azuresb.servicebus.windows.net]
2022-01-19 23:58:40,982 INFO  [com.azu.cor.amq.imp.han.ReactorHandler] (reactor-executor-1) connectionId[MF_167a3f_1642633120898] reactor.onReactorInit
2022-01-19 23:58:40,983 INFO  [com.azu.cor.amq.imp.han.ConnectionHandler] (reactor-executor-1) onConnectionLocalOpen connectionId[MF_167a3f_1642633120898] hostname[my-azuresb.servicebus.windows.net] errorCondition[null] errorDescription[null]
2022-01-19 23:58:40,992 INFO  [com.azu.mes.ser.FluxAutoComplete] (Quarkus Main Thread) Subscription received. Subscribing downstream. reactor.core.publisher.FluxMap$MapSubscriber@3d684327
2022-01-19 23:58:40,994 INFO  [org.apa.cam.imp.eng.AbstractCamelContext] (Quarkus Main Thread) Routes startup summary (total:1 started:1)
2022-01-19 23:58:40,994 INFO  [org.apa.cam.imp.eng.AbstractCamelContext] (Quarkus Main Thread)     Started route1 (azure-servicebus://source-in)
2022-01-19 23:58:40,995 INFO  [org.apa.cam.imp.eng.AbstractCamelContext] (Quarkus Main Thread) Apache Camel 3.13.0 (camel-1) started in 382ms (build:68ms init:81ms start:233ms)
2022-01-19 23:58:41,002 INFO  [io.quarkus] (Quarkus Main Thread) code-with-quarkus-camel 1.0.0-SNAPSHOT on JVM (powered by Quarkus 2.6.2.Final) started in 1.724s. 
2022-01-19 23:58:41,003 INFO  [io.quarkus] (Quarkus Main Thread) Profile dev activated. Live Coding activated.
2022-01-19 23:58:41,004 INFO  [io.quarkus] (Quarkus Main Thread) Installed features: [cdi, smallrye-context-propagation, smallrye-reactive-messaging, vertx]
2022-01-19 23:58:41,042 INFO  [com.azu.cor.amq.imp.han.ConnectionHandler] (reactor-executor-1) onConnectionBound connectionId[MF_167a3f_1642633120898] hostname[my-azuresb.servicebus.windows.net] peerDetails[my-azuresb.servicebus.windows.net:443]
2022-01-19 23:58:41,042 INFO  [com.azu.cor.amq.imp.han.WebSocketsConnectionHandler] (reactor-executor-1) Adding web socket layer
2022-01-19 23:58:41,519 INFO  [com.azu.cor.amq.imp.han.ConnectionHandler] (reactor-executor-1) onConnectionRemoteOpen hostname[my-azuresb.servicebus.windows.net], connectionId[MF_167a3f_1642633120898], remoteContainer[215ad176b4464c4488eba3ba48b74039_G10]
2022-01-19 23:58:41,519 INFO  [com.azu.mes.ser.imp.ServiceBusConnectionProcessor] (reactor-executor-1) namespace[my-azuresb.servicebus.windows.net] entityPath[N/A]: Channel is now active.
2022-01-19 23:58:41,558 INFO  [com.azu.cor.amq.imp.han.SessionHandler] (reactor-executor-1) onSessionRemoteOpen connectionId[MF_167a3f_1642633120898], entityName[source-in/subscriptions/source-in-subscription], sessionIncCapacity[0], sessionOutgoingWindow[2147483647]
2022-01-19 23:58:41,567 INFO  [com.azu.cor.amq.imp.ReactorConnection] (reactor-executor-1) Setting CBS channel.
2022-01-19 23:58:41,598 INFO  [com.azu.cor.amq.imp.han.SessionHandler] (reactor-executor-1) onSessionRemoteOpen connectionId[MF_167a3f_1642633120898], entityName[cbs-session], sessionIncCapacity[0], sessionOutgoingWindow[2147483647]
2022-01-19 23:58:41,605 INFO  [com.azu.cor.amq.imp.ReactorConnection] (reactor-executor-1) connectionId[MF_167a3f_1642633120898] entityPath[$cbs] linkName[cbs] Emitting new response channel.
2022-01-19 23:58:41,605 INFO  [com.azu.cor.amq.imp.RequestResponseChannel:$cbs] (reactor-executor-1) namespace[MF_167a3f_1642633120898] entityPath[$cbs]: Setting next AMQP channel.
2022-01-19 23:58:41,606 INFO  [com.azu.cor.amq.imp.RequestResponseChannel:$cbs] (reactor-executor-1) namespace[MF_167a3f_1642633120898] entityPath[$cbs]: Next AMQP channel received, updating 1 current subscribers
2022-01-19 23:58:41,639 INFO  [com.azu.cor.amq.imp.han.SendLinkHandler] (reactor-executor-1) onLinkRemoteOpen connectionId[MF_167a3f_1642633120898], entityPath[$cbs], linkName[cbs:sender], remoteTarget[Target{address='$cbs', durable=NONE, expiryPolicy=SESSION_END, timeout=0, dynamic=false, dynamicNodeProperties=null, capabilities=null}]
2022-01-19 23:58:41,640 INFO  [com.azu.cor.amq.imp.han.ReceiveLinkHandler] (reactor-executor-1) onLinkRemoteOpen connectionId[MF_167a3f_1642633120898], entityPath[$cbs], linkName[cbs:receiver], remoteSource[Source{address='$cbs', durable=NONE, expiryPolicy=SESSION_END, timeout=0, dynamic=false, dynamicNodeProperties=null, distributionMode=null, filter=null, defaultOutcome=null, outcomes=null, capabilities=null}]
2022-01-19 23:58:41,640 INFO  [com.azu.cor.amq.imp.RequestResponseChannel:$cbs] (reactor-executor-1) namespace[MF_167a3f_1642633120898] entityPath[$cbs]: Channel is now active.
2022-01-19 23:58:41,671 INFO  [com.azu.cor.amq.imp.ActiveClientTokenManager] (reactor-executor-1) Scheduling refresh token task. scopes[amqp://my-azuresb.servicebus.windows.net/source-in/subscriptions/source-in-subscription]
2022-01-19 23:58:41,677 INFO  [com.azu.cor.amq.imp.ReactorSession] (reactor-executor-1) connectionId[MF_167a3f_1642633120898] sessionId[source-in/subscriptions/source-in-subscription] linkName[source-in/subscriptions/source-in-subscription_74188f_1642633120942] Creating a new receiver link.
2022-01-19 23:58:41,682 INFO  [com.azu.mes.ser.imp.ServiceBusReceiveLinkProcessor] (reactor-executor-1) linkName[source-in/subscriptions/source-in-subscription_74188f_1642633120942] entityPath[source-in/subscriptions/source-in-subscription]. Setting next AMQP receive link.
2022-01-19 23:58:41,692 INFO  [com.azu.mes.ser.imp.ServiceBusReceiveLinkProcessor] (reactor-executor-1) linkCredits: '0', expectedTotalCredit: '1'
2022-01-19 23:58:41,692 INFO  [com.azu.mes.ser.imp.ServiceBusReceiveLinkProcessor] (reactor-executor-1) prefetch: '0', requested: '1', linkCredits: '0', expectedTotalCredit: '1', queuedMessages:'0', creditsToAdd: '1', messageQueue.size(): '0'
2022-01-19 23:58:41,693 INFO  [com.azu.mes.ser.imp.ServiceBusReceiveLinkProcessor] (reactor-executor-1) Link credits='0', Link credits to add: '1'
2022-01-19 23:58:41,695 INFO  [com.azu.cor.amq.imp.ReactorSession] (reactor-executor-1) linkName[source-in/subscriptions/source-in-subscription_74188f_1642633120942] entityPath[source-in/subscriptions/source-in-subscription] Returning existing receive link.
2022-01-19 23:58:41,730 INFO  [com.azu.cor.amq.imp.han.ReceiveLinkHandler] (reactor-executor-1) onLinkRemoteOpen connectionId[MF_167a3f_1642633120898], entityPath[source-in/subscriptions/source-in-subscription], linkName[source-in/subscriptions/source-in-subscription_74188f_1642633120942], remoteSource[Source{address='source-in/subscriptions/source-in-subscription', durable=NONE, expiryPolicy=SESSION_END, timeout=0, dynamic=false, dynamicNodeProperties=null, distributionMode=null, filter=null, defaultOutcome=null, outcomes=null, capabilities=null}]
2022-01-19 23:59:12,246 INFO  [com.azu.cor.imp.jac.JacksonVersion] (boundedElastic-2) Package versions: jackson-annotations=2.12.6, jackson-core=2.12.6, jackson-databind=2.12.6, jackson-dataformat-xml=2.12.6, jackson-datatype-jsr310=2.12.6, azure-core=1.21.0
2022-01-19 23:59:12,418 ERROR [org.apa.cam.pro.err.DefaultErrorHandler] (boundedElastic-2) Failed delivery for (MessageId: 27C071FB177B97B-0000000000000001 on ExchangeId: 27C071FB177B97B-0000000000000001). Exhausted after delivery attempt: 1 caught: java.lang.IllegalStateException: The stream has no active subscriptions

Message History (complete message history is disabled)
---------------------------------------------------------------------------------------------------------------------------------------
RouteId              ProcessorId          Processor                                                                        Elapsed (ms)
[route1            ] [route1            ] [from[azure-servicebus://source-in?amqpTransportType=AmqpWebSockets&] [       253]
	...
[route1            ] [to1               ] [reactive-streams:27C071FB177B97B-0000000000000000                             ] [         0]

Stacktrace
---------------------------------------------------------------------------------------------------------------------------------------
: java.lang.IllegalStateException: The stream has no active subscriptions
	at org.apache.camel.component.reactive.streams.engine.CamelPublisher.publish(CamelPublisher.java:110)
	at org.apache.camel.component.reactive.streams.engine.DefaultCamelReactiveStreamsService.sendCamelExchange(DefaultCamelReactiveStreamsService.java:151)
	at org.apache.camel.component.reactive.streams.ReactiveStreamsProducer.process(ReactiveStreamsProducer.java:52)
	at org.apache.camel.processor.SendProcessor.process(SendProcessor.java:172)
	at org.apache.camel.processor.errorhandler.RedeliveryErrorHandler$SimpleTask.run(RedeliveryErrorHandler.java:469)
	at org.apache.camel.impl.engine.DefaultReactiveExecutor$Worker.schedule(DefaultReactiveExecutor.java:187)
	at org.apache.camel.impl.engine.DefaultReactiveExecutor.scheduleMain(DefaultReactiveExecutor.java:64)
	at org.apache.camel.processor.Pipeline.process(Pipeline.java:184)
	at org.apache.camel.impl.engine.CamelInternalProcessor.process(CamelInternalProcessor.java:398)
	at org.apache.camel.component.azure.servicebus.ServiceBusConsumer.onEventListener(ServiceBusConsumer.java:147)
	at reactor.core.publisher.LambdaSubscriber.onNext(LambdaSubscriber.java:160)
	at reactor.core.publisher.FluxPublishOn$PublishOnSubscriber.runAsync(FluxPublishOn.java:440)
	at reactor.core.publisher.FluxPublishOn$PublishOnSubscriber.run(FluxPublishOn.java:527)
	at reactor.core.scheduler.ImmediateScheduler$ImmediateSchedulerWorker.schedule(ImmediateScheduler.java:84)
	at reactor.core.publisher.FluxPublishOn$PublishOnSubscriber.trySchedule(FluxPublishOn.java:312)
	at reactor.core.publisher.FluxPublishOn$PublishOnSubscriber.onNext(FluxPublishOn.java:237)
	at reactor.core.publisher.FluxHandle$HandleSubscriber.onNext(FluxHandle.java:119)
	at reactor.core.publisher.FluxOnErrorResume$ResumeSubscriber.onNext(FluxOnErrorResume.java:79)
	at com.azure.messaging.servicebus.FluxAutoComplete$AutoCompleteSubscriber.hookOnNext(FluxAutoComplete.java:89)
	at com.azure.messaging.servicebus.FluxAutoComplete$AutoCompleteSubscriber.hookOnNext(FluxAutoComplete.java:52)
	at reactor.core.publisher.BaseSubscriber.onNext(BaseSubscriber.java:160)
	at com.azure.messaging.servicebus.FluxAutoLockRenew$LockRenewSubscriber.hookOnNext(FluxAutoLockRenew.java:171)
	at com.azure.messaging.servicebus.FluxAutoLockRenew$LockRenewSubscriber.hookOnNext(FluxAutoLockRenew.java:76)
	at reactor.core.publisher.BaseSubscriber.onNext(BaseSubscriber.java:160)
	at reactor.core.publisher.FluxMap$MapSubscriber.onNext(FluxMap.java:120)
	at reactor.core.publisher.FluxMap$MapSubscriber.onNext(FluxMap.java:120)
	at com.azure.messaging.servicebus.implementation.ServiceBusReceiveLinkProcessor.drainQueue(ServiceBusReceiveLinkProcessor.java:478)
	at com.azure.messaging.servicebus.implementation.ServiceBusReceiveLinkProcessor.drain(ServiceBusReceiveLinkProcessor.java:437)
	at com.azure.messaging.servicebus.implementation.ServiceBusReceiveLinkProcessor.lambda$onNext$2(ServiceBusReceiveLinkProcessor.java:210)
	at reactor.core.publisher.LambdaSubscriber.onNext(LambdaSubscriber.java:160)
	at reactor.core.publisher.FluxPublishOn$PublishOnSubscriber.runAsync(FluxPublishOn.java:440)
	at reactor.core.publisher.FluxPublishOn$PublishOnSubscriber.run(FluxPublishOn.java:527)
	at reactor.core.scheduler.WorkerTask.call(WorkerTask.java:84)
	at reactor.core.scheduler.WorkerTask.call(WorkerTask.java:37)
	at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
	at java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
	at java.base/java.lang.Thread.run(Thread.java:833)

2022-01-19 23:59:12,422 WARN  [org.apa.cam.com.azu.ser.ServiceBusConsumer] (boundedElastic-2) Error during processing exchange.. Exchange[27C071FB177B97B-0000000000000001]. Caused by: [java.lang.IllegalStateException - The stream has no active subscriptions]: java.lang.IllegalStateException: The stream has no active subscriptions
	at org.apache.camel.component.reactive.streams.engine.CamelPublisher.publish(CamelPublisher.java:110)
	at org.apache.camel.component.reactive.streams.engine.DefaultCamelReactiveStreamsService.sendCamelExchange(DefaultCamelReactiveStreamsService.java:151)
	at org.apache.camel.component.reactive.streams.ReactiveStreamsProducer.process(ReactiveStreamsProducer.java:52)
	at org.apache.camel.processor.SendProcessor.process(SendProcessor.java:172)
	at org.apache.camel.processor.errorhandler.RedeliveryErrorHandler$SimpleTask.run(RedeliveryErrorHandler.java:469)
	at org.apache.camel.impl.engine.DefaultReactiveExecutor$Worker.schedule(DefaultReactiveExecutor.java:187)
	at org.apache.camel.impl.engine.DefaultReactiveExecutor.scheduleMain(DefaultReactiveExecutor.java:64)
	at org.apache.camel.processor.Pipeline.process(Pipeline.java:184)
	at org.apache.camel.impl.engine.CamelInternalProcessor.process(CamelInternalProcessor.java:398)
	at org.apache.camel.component.azure.servicebus.ServiceBusConsumer.onEventListener(ServiceBusConsumer.java:147)
	at reactor.core.publisher.LambdaSubscriber.onNext(LambdaSubscriber.java:160)
	at reactor.core.publisher.FluxPublishOn$PublishOnSubscriber.runAsync(FluxPublishOn.java:440)
	at reactor.core.publisher.FluxPublishOn$PublishOnSubscriber.run(FluxPublishOn.java:527)
	at reactor.core.scheduler.ImmediateScheduler$ImmediateSchedulerWorker.schedule(ImmediateScheduler.java:84)
	at reactor.core.publisher.FluxPublishOn$PublishOnSubscriber.trySchedule(FluxPublishOn.java:312)
	at reactor.core.publisher.FluxPublishOn$PublishOnSubscriber.onNext(FluxPublishOn.java:237)
	at reactor.core.publisher.FluxHandle$HandleSubscriber.onNext(FluxHandle.java:119)
	at reactor.core.publisher.FluxOnErrorResume$ResumeSubscriber.onNext(FluxOnErrorResume.java:79)
	at com.azure.messaging.servicebus.FluxAutoComplete$AutoCompleteSubscriber.hookOnNext(FluxAutoComplete.java:89)
	at com.azure.messaging.servicebus.FluxAutoComplete$AutoCompleteSubscriber.hookOnNext(FluxAutoComplete.java:52)
	at reactor.core.publisher.BaseSubscriber.onNext(BaseSubscriber.java:160)
	at com.azure.messaging.servicebus.FluxAutoLockRenew$LockRenewSubscriber.hookOnNext(FluxAutoLockRenew.java:171)
	at com.azure.messaging.servicebus.FluxAutoLockRenew$LockRenewSubscriber.hookOnNext(FluxAutoLockRenew.java:76)
	at reactor.core.publisher.BaseSubscriber.onNext(BaseSubscriber.java:160)
	at reactor.core.publisher.FluxMap$MapSubscriber.onNext(FluxMap.java:120)
	at reactor.core.publisher.FluxMap$MapSubscriber.onNext(FluxMap.java:120)
	at com.azure.messaging.servicebus.implementation.ServiceBusReceiveLinkProcessor.drainQueue(ServiceBusReceiveLinkProcessor.java:478)
	at com.azure.messaging.servicebus.implementation.ServiceBusReceiveLinkProcessor.drain(ServiceBusReceiveLinkProcessor.java:437)
	at com.azure.messaging.servicebus.implementation.ServiceBusReceiveLinkProcessor.lambda$onNext$2(ServiceBusReceiveLinkProcessor.java:210)
	at reactor.core.publisher.LambdaSubscriber.onNext(LambdaSubscriber.java:160)
	at reactor.core.publisher.FluxPublishOn$PublishOnSubscriber.runAsync(FluxPublishOn.java:440)
	at reactor.core.publisher.FluxPublishOn$PublishOnSubscriber.run(FluxPublishOn.java:527)
	at reactor.core.scheduler.WorkerTask.call(WorkerTask.java:84)
	at reactor.core.scheduler.WorkerTask.call(WorkerTask.java:37)
	at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
	at java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
	at java.base/java.lang.Thread.run(Thread.java:833)

2022-01-19 23:59:12,424 WARN  [org.apa.cam.com.azu.ser.ServiceBusConsumer] (boundedElastic-2) Error processing exchange. Exchange[27C071FB177B97B-0000000000000001]. Caused by: [java.lang.IllegalStateException - The stream has no active subscriptions]: java.lang.IllegalStateException: The stream has no active subscriptions
	at org.apache.camel.component.reactive.streams.engine.CamelPublisher.publish(CamelPublisher.java:110)
	at org.apache.camel.component.reactive.streams.engine.DefaultCamelReactiveStreamsService.sendCamelExchange(DefaultCamelReactiveStreamsService.java:151)
	at org.apache.camel.component.reactive.streams.ReactiveStreamsProducer.process(ReactiveStreamsProducer.java:52)
	at org.apache.camel.processor.SendProcessor.process(SendProcessor.java:172)
	at org.apache.camel.processor.errorhandler.RedeliveryErrorHandler$SimpleTask.run(RedeliveryErrorHandler.java:469)
	at org.apache.camel.impl.engine.DefaultReactiveExecutor$Worker.schedule(DefaultReactiveExecutor.java:187)
	at org.apache.camel.impl.engine.DefaultReactiveExecutor.scheduleMain(DefaultReactiveExecutor.java:64)
	at org.apache.camel.processor.Pipeline.process(Pipeline.java:184)
	at org.apache.camel.impl.engine.CamelInternalProcessor.process(CamelInternalProcessor.java:398)
	at org.apache.camel.component.azure.servicebus.ServiceBusConsumer.onEventListener(ServiceBusConsumer.java:147)
	at reactor.core.publisher.LambdaSubscriber.onNext(LambdaSubscriber.java:160)
	at reactor.core.publisher.FluxPublishOn$PublishOnSubscriber.runAsync(FluxPublishOn.java:440)
	at reactor.core.publisher.FluxPublishOn$PublishOnSubscriber.run(FluxPublishOn.java:527)
	at reactor.core.scheduler.ImmediateScheduler$ImmediateSchedulerWorker.schedule(ImmediateScheduler.java:84)
	at reactor.core.publisher.FluxPublishOn$PublishOnSubscriber.trySchedule(FluxPublishOn.java:312)
	at reactor.core.publisher.FluxPublishOn$PublishOnSubscriber.onNext(FluxPublishOn.java:237)
	at reactor.core.publisher.FluxHandle$HandleSubscriber.onNext(FluxHandle.java:119)
	at reactor.core.publisher.FluxOnErrorResume$ResumeSubscriber.onNext(FluxOnErrorResume.java:79)
	at com.azure.messaging.servicebus.FluxAutoComplete$AutoCompleteSubscriber.hookOnNext(FluxAutoComplete.java:89)
	at com.azure.messaging.servicebus.FluxAutoComplete$AutoCompleteSubscriber.hookOnNext(FluxAutoComplete.java:52)
	at reactor.core.publisher.BaseSubscriber.onNext(BaseSubscriber.java:160)
	at com.azure.messaging.servicebus.FluxAutoLockRenew$LockRenewSubscriber.hookOnNext(FluxAutoLockRenew.java:171)
	at com.azure.messaging.servicebus.FluxAutoLockRenew$LockRenewSubscriber.hookOnNext(FluxAutoLockRenew.java:76)
	at reactor.core.publisher.BaseSubscriber.onNext(BaseSubscriber.java:160)
	at reactor.core.publisher.FluxMap$MapSubscriber.onNext(FluxMap.java:120)
	at reactor.core.publisher.FluxMap$MapSubscriber.onNext(FluxMap.java:120)
	at com.azure.messaging.servicebus.implementation.ServiceBusReceiveLinkProcessor.drainQueue(ServiceBusReceiveLinkProcessor.java:478)
	at com.azure.messaging.servicebus.implementation.ServiceBusReceiveLinkProcessor.drain(ServiceBusReceiveLinkProcessor.java:437)
	at com.azure.messaging.servicebus.implementation.ServiceBusReceiveLinkProcessor.lambda$onNext$2(ServiceBusReceiveLinkProcessor.java:210)
	at reactor.core.publisher.LambdaSubscriber.onNext(LambdaSubscriber.java:160)
	at reactor.core.publisher.FluxPublishOn$PublishOnSubscriber.runAsync(FluxPublishOn.java:440)
	at reactor.core.publisher.FluxPublishOn$PublishOnSubscriber.run(FluxPublishOn.java:527)
	at reactor.core.scheduler.WorkerTask.call(WorkerTask.java:84)
	at reactor.core.scheduler.WorkerTask.call(WorkerTask.java:37)
	at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
	at java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
	at java.base/java.lang.Thread.run(Thread.java:833)

2022-01-19 23:59:12,425 INFO  [com.azu.mes.ser.imp.ServiceBusReceiveLinkProcessor] (boundedElastic-2) linkCredits: '0', expectedTotalCredit: '2'
2022-01-19 23:59:12,425 INFO  [com.azu.mes.ser.imp.ServiceBusReceiveLinkProcessor] (boundedElastic-2) prefetch: '0', requested: '2', linkCredits: '0', expectedTotalCredit: '2', queuedMessages:'1', creditsToAdd: '1', messageQueue.size(): '0'
2022-01-19 23:59:12,425 INFO  [com.azu.mes.ser.imp.ServiceBusReceiveLinkProcessor] (boundedElastic-2) Link credits='0', Link credits to add: '1'
@jamesnetherton
Copy link
Contributor

Can you try it without the CamelContextProducer? Creating & managing your own CamelContext is something we discourage because Camel Quarkus assembles one for you at build time with various optimizations.

Also add a dependency on camel-quarkus-smallrye-reactive-messaging.

@freedev
Copy link
Author

freedev commented Jan 20, 2022

Hi James, thanks for coming back to me! :)In the first instance I've tried CamelContextProducer without but failed to start quarkus.

 [1] Unsatisfied dependency for type org.apache.camel.CamelContext and qualifiers [@Default]

This is the log:

 ~/git/personal/quarkus/code-with-quarkus-camel  master !2 ?1  mvn clean quarkus:dev                                                                                            ok
[INFO] Scanning for projects...
[INFO]
[INFO] ------------< t.lux.quarkus.azure:code-with-quarkus-camel >-------------
[INFO] Building code-with-quarkus-camel 1.0.0-SNAPSHOT
[INFO] --------------------------------[ jar ]---------------------------------
[INFO]
[INFO] --- maven-clean-plugin:2.5:clean (default-clean) @ code-with-quarkus-camel ---
[INFO] Deleting /Users/freedev/git/personal/quarkus/code-with-quarkus-camel/target
[INFO]
[INFO] --- quarkus-maven-plugin:2.6.2.Final:dev (default-cli) @ code-with-quarkus-camel ---
[INFO] Invoking org.apache.maven.plugins:maven-resources-plugin:2.6:resources) @ code-with-quarkus-camel
[INFO] Using 'UTF-8' encoding to copy filtered resources.
[INFO] Copying 1 resource
[INFO] Invoking io.quarkus.platform:quarkus-maven-plugin:2.6.2.Final:generate-code) @ code-with-quarkus-camel
[INFO] Invoking org.apache.maven.plugins:maven-compiler-plugin:3.8.1:compile) @ code-with-quarkus-camel
[INFO] Changes detected - recompiling the module!
[INFO] Compiling 1 source file to /Users/freedev/git/personal/quarkus/code-with-quarkus-camel/target/classes
[INFO] Invoking org.apache.maven.plugins:maven-resources-plugin:2.6:testResources) @ code-with-quarkus-camel
[INFO] Using 'UTF-8' encoding to copy filtered resources.
[INFO] skip non existing resourceDirectory /Users/freedev/git/personal/quarkus/code-with-quarkus-camel/src/test/resources
[INFO] Invoking io.quarkus.platform:quarkus-maven-plugin:2.6.2.Final:generate-code-tests) @ code-with-quarkus-camel
[INFO] Invoking org.apache.maven.plugins:maven-compiler-plugin:3.8.1:testCompile) @ code-with-quarkus-camel
[INFO] Changes detected - recompiling the module!
Listening for transport dt_socket at address: 5005
2022-01-20 09:46:36,533 INFO  [io.qua.dep.dev.IsolatedDevModeMain] (main) Attempting to start live reload endpoint to recover from previous Quarkus startup failure
2022-01-20 09:46:36,588 ERROR [io.qua.dep.dev.IsolatedDevModeMain] (main) Failed to start quarkus: java.lang.RuntimeException: io.quarkus.builder.BuildException: Build failure: Build failed due to errors
	[error]: Build step io.quarkus.arc.deployment.ArcProcessor#validate threw an exception: javax.enterprise.inject.spi.DeploymentException: Found 2 deployment problems:
[1] Unsatisfied dependency for type org.apache.camel.CamelContext and qualifiers [@Default]
	- java member: t.lux.quarkus.azure.MyReactiveMessagingApplication#camelContext
	- declared on CLASS bean [types=[t.lux.quarkus.azure.MyReactiveMessagingApplication, java.lang.Object], qualifiers=[@Default, @Any], target=t.lux.quarkus.azure.MyReactiveMessagingApplication]
[2] Unsatisfied dependency for type org.apache.camel.CamelContext and qualifiers [@Default]
	- java member: io.smallrye.reactive.messaging.camel.CamelConnector#camel
	- declared on CLASS bean [types=[org.eclipse.microprofile.reactive.messaging.spi.ConnectorFactory, org.eclipse.microprofile.reactive.messaging.spi.OutgoingConnectorFactory, io.smallrye.reactive.messaging.camel.CamelConnector, org.eclipse.microprofile.reactive.messaging.spi.IncomingConnectorFactory, java.lang.Object], qualifiers=[@Connector(value = "smallrye-camel"), @Any], target=io.smallrye.reactive.messaging.camel.CamelConnector]
	at io.quarkus.arc.processor.BeanDeployment.processErrors(BeanDeployment.java:1204)
	at io.quarkus.arc.processor.BeanDeployment.init(BeanDeployment.java:269)
	at io.quarkus.arc.processor.BeanProcessor.initialize(BeanProcessor.java:134)
	at io.quarkus.arc.deployment.ArcProcessor.validate(ArcProcessor.java:454)
	at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
	at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.base/java.lang.reflect.Method.invoke(Method.java:566)
	at io.quarkus.deployment.ExtensionLoader$2.execute(ExtensionLoader.java:887)
	at io.quarkus.builder.BuildContext.run(BuildContext.java:277)
	at org.jboss.threads.ContextHandler$1.runWith(ContextHandler.java:18)
	at org.jboss.threads.EnhancedQueueExecutor$Task.run(EnhancedQueueExecutor.java:2449)
	at org.jboss.threads.EnhancedQueueExecutor$ThreadBody.run(EnhancedQueueExecutor.java:1478)
	at java.base/java.lang.Thread.run(Thread.java:829)
	at org.jboss.threads.JBossThread.run(JBossThread.java:501)
	Suppressed: javax.enterprise.inject.UnsatisfiedResolutionException: Unsatisfied dependency for type org.apache.camel.CamelContext and qualifiers [@Default]
	- java member: t.lux.quarkus.azure.MyReactiveMessagingApplication#camelContext
	- declared on CLASS bean [types=[t.lux.quarkus.azure.MyReactiveMessagingApplication, java.lang.Object], qualifiers=[@Default, @Any], target=t.lux.quarkus.azure.MyReactiveMessagingApplication]
		at io.quarkus.arc.processor.Beans.resolveInjectionPoint(Beans.java:428)
		at io.quarkus.arc.processor.BeanInfo.init(BeanInfo.java:508)
		at io.quarkus.arc.processor.BeanDeployment.init(BeanDeployment.java:257)
		... 13 more
	Suppressed: javax.enterprise.inject.UnsatisfiedResolutionException: Unsatisfied dependency for type org.apache.camel.CamelContext and qualifiers [@Default]
	- java member: io.smallrye.reactive.messaging.camel.CamelConnector#camel
	- declared on CLASS bean [types=[org.eclipse.microprofile.reactive.messaging.spi.ConnectorFactory, org.eclipse.microprofile.reactive.messaging.spi.OutgoingConnectorFactory, io.smallrye.reactive.messaging.camel.CamelConnector, org.eclipse.microprofile.reactive.messaging.spi.IncomingConnectorFactory, java.lang.Object], qualifiers=[@Connector(value = "smallrye-camel"), @Any], target=io.smallrye.reactive.messaging.camel.CamelConnector]
		at io.quarkus.arc.processor.Beans.resolveInjectionPoint(Beans.java:428)
		at io.quarkus.arc.processor.BeanInfo.init(BeanInfo.java:508)
		at io.quarkus.arc.processor.BeanDeployment.init(BeanDeployment.java:257)
		... 13 more

	at io.quarkus.runner.bootstrap.AugmentActionImpl.runAugment(AugmentActionImpl.java:330)
	at io.quarkus.runner.bootstrap.AugmentActionImpl.createInitialRuntimeApplication(AugmentActionImpl.java:252)
	at io.quarkus.runner.bootstrap.AugmentActionImpl.createInitialRuntimeApplication(AugmentActionImpl.java:60)
	at io.quarkus.deployment.dev.IsolatedDevModeMain.firstStart(IsolatedDevModeMain.java:93)
	at io.quarkus.deployment.dev.IsolatedDevModeMain.accept(IsolatedDevModeMain.java:456)
	at io.quarkus.deployment.dev.IsolatedDevModeMain.accept(IsolatedDevModeMain.java:67)
	at io.quarkus.bootstrap.app.CuratedApplication.runInCl(CuratedApplication.java:149)
	at io.quarkus.bootstrap.app.CuratedApplication.runInAugmentClassLoader(CuratedApplication.java:105)
	at io.quarkus.deployment.dev.DevModeMain.start(DevModeMain.java:145)
	at io.quarkus.deployment.dev.DevModeMain.main(DevModeMain.java:63)
Caused by: io.quarkus.builder.BuildException: Build failure: Build failed due to errors
	[error]: Build step io.quarkus.arc.deployment.ArcProcessor#validate threw an exception: javax.enterprise.inject.spi.DeploymentException: Found 2 deployment problems:
[1] Unsatisfied dependency for type org.apache.camel.CamelContext and qualifiers [@Default]
	- java member: t.lux.quarkus.azure.MyReactiveMessagingApplication#camelContext
	- declared on CLASS bean [types=[t.lux.quarkus.azure.MyReactiveMessagingApplication, java.lang.Object], qualifiers=[@Default, @Any], target=t.lux.quarkus.azure.MyReactiveMessagingApplication]
[2] Unsatisfied dependency for type org.apache.camel.CamelContext and qualifiers [@Default]
	- java member: io.smallrye.reactive.messaging.camel.CamelConnector#camel
	- declared on CLASS bean [types=[org.eclipse.microprofile.reactive.messaging.spi.ConnectorFactory, org.eclipse.microprofile.reactive.messaging.spi.OutgoingConnectorFactory, io.smallrye.reactive.messaging.camel.CamelConnector, org.eclipse.microprofile.reactive.messaging.spi.IncomingConnectorFactory, java.lang.Object], qualifiers=[@Connector(value = "smallrye-camel"), @Any], target=io.smallrye.reactive.messaging.camel.CamelConnector]
	at io.quarkus.arc.processor.BeanDeployment.processErrors(BeanDeployment.java:1204)
	at io.quarkus.arc.processor.BeanDeployment.init(BeanDeployment.java:269)
	at io.quarkus.arc.processor.BeanProcessor.initialize(BeanProcessor.java:134)
	at io.quarkus.arc.deployment.ArcProcessor.validate(ArcProcessor.java:454)
	at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
	at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.base/java.lang.reflect.Method.invoke(Method.java:566)
	at io.quarkus.deployment.ExtensionLoader$2.execute(ExtensionLoader.java:887)
	at io.quarkus.builder.BuildContext.run(BuildContext.java:277)
	at org.jboss.threads.ContextHandler$1.runWith(ContextHandler.java:18)
	at org.jboss.threads.EnhancedQueueExecutor$Task.run(EnhancedQueueExecutor.java:2449)
	at org.jboss.threads.EnhancedQueueExecutor$ThreadBody.run(EnhancedQueueExecutor.java:1478)
	at java.base/java.lang.Thread.run(Thread.java:829)
	at org.jboss.threads.JBossThread.run(JBossThread.java:501)
	Suppressed: javax.enterprise.inject.UnsatisfiedResolutionException: Unsatisfied dependency for type org.apache.camel.CamelContext and qualifiers [@Default]
	- java member: t.lux.quarkus.azure.MyReactiveMessagingApplication#camelContext
	- declared on CLASS bean [types=[t.lux.quarkus.azure.MyReactiveMessagingApplication, java.lang.Object], qualifiers=[@Default, @Any], target=t.lux.quarkus.azure.MyReactiveMessagingApplication]
		at io.quarkus.arc.processor.Beans.resolveInjectionPoint(Beans.java:428)
		at io.quarkus.arc.processor.BeanInfo.init(BeanInfo.java:508)
		at io.quarkus.arc.processor.BeanD(BeanDeployment.java:257)
		... 13 more
	Suppressed: javax.enterprise.inject.UnsatisfiedResolutionException: Unsatisfied dependency for type org.apache.camel.CamelContext and qualifiers [@Default]
	- java member: io.smallrye.reactive.messaging.camel.CamelConnector#camel
	- declared on CLASS bean [types=[org.eclipse.microprofile.reactive.messaging.spi.ConnectorFactory, org.eclipse.microprofile.reactive.messaging.spi.OutgoingConnectorFactory, io.smallrye.reactive.messaging.camel.CamelConnector, org.eclipse.microprofile.reactive.messaging.spi.IncomingConnectorFactory, java.lang.Object], qualifiers=[@Connector(value = "smallrye-camel"), @Any], target=io.smallrye.reactive.messaging.camel.CamelConnector]
		at io.quarkus.arc.processor.Beans.resolveInjectionPoint(Beans.java:428)
		at io.quarkus.arc.processor.BeanInfo.init(BeanInfo.java:508)
		at io.quarkus.arc.processor.BeanDeployment.init(BeanDeployment.java:257)
		... 13 more

	at io.quarkus.builder.Execution.run(Execution.java:116)
	at io.quarkus.builder.BuildExecutionBuilder.execute(BuildExecutionBuilder.java:79)
	at io.quarkus.deployment.QuarkusAugmentor.run(QuarkusAugmentor.java:161)
	at io.quarkus.runner.bootstrap.AugmentActionImpl.runAugment(AugmentActionImpl.java:328)
	... 9 more
Caused by: javax.enterprise.inject.spi.DeploymentException: Found 2 deployment problems:
[1] Unsatisfied dependency for type org.apache.camel.CamelContext and qualifiers [@Default]
	- java member: t.lux.quarkus.azure.MyReactiveMessagingApplication#camelContext
	- declared on CLASS bean [types=[t.lux.quarkus.azure.MyReactiveMessagingApplication, java.lang.Object], qualifiers=[@Default, @Any], target=t.lux.quarkus.azure.MyReactiveMessagingApplication]
[2] Unsatisfied dependency for type org.apache.camel.CamelContext and qualifiers [@Default]
	- java member: io.smallrye.reactive.messaging.camel.CamelConnector#camel
	- declared on CLASS bean [types=[org.eclipse.microprofile.reactive.messaging.spi.ConnectorFactory, org.eclipse.microprofile.reactive.messaging.spi.OutgoingConnectorFactory, io.smallrye.reactive.messaging.camel.CamelConnector, org.eclipse.microprofile.reactive.messaging.spi.IncomingConnectorFactory, java.lang.Object], qualifiers=[@Connector(value = "smallrye-camel"), @Any], target=io.smallrye.reactive.messaging.camel.CamelConnector]
	at io.quarkus.arc.processor.BeanDeployment.processErrors(BeanDeployment.java:1204)
	at io.quarkus.arc.processor.BeanDeployment.init(BeanDeployment.java:269)
	at io.quarkus.arc.processor.BeanProcessor.initialize(BeanProcessor.java:134)
	at io.quarkus.arc.deployment.ArcProcessor.validate(ArcProcessor.java:454)
	at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
	at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.base/java.lang.reflect.Method.invoke(Method.java:566)
	at io.quarkus.deployment.ExtensionLoader$2.execute(ExtensionLoader.java:887)
	at io.quarkus.builder.BuildContext.run(BuildContext.java:277)
	at org.jboss.threads.ContextHandler$1.runWith(ContextHandler.java:18)
	at org.jboss.threads.EnhancedQueueExecutor$Task.run(EnhancedQueueExecutor.java:2449)
	at org.jboss.threads.EnhancedQueueExecutor$ThreadBody.run(EnhancedQueueExecutor.java:1478)
	at java.base/java.lang.Thread.run(Thread.java:829)
	at org.jboss.threads.JBossThread.run(JBossThread.java:501)
	Suppressed: javax.enterprise.inject.UnsatisfiedResolutionException: Unsatisfied dependency for type org.apache.camel.CamelContext and qualifiers [@Default]
	- java member: t.lux.quarkus.azure.MyReactiveMessagingApplication#camelContext
	- declared on CLASS bean [types=[t.lux.quarkus.azure.MyReactiveMessagingApplication, java.lang.Object], qualifiers=[@Default, @Any], target=t.lux.quarkus.azure.MyReactiveMessagingApplication]
		at io.quarkus.arc.processor.Beans.resolveInjectionPoint(Beans.java:428)
		at io.quarkus.arc.processor.BeanInfo.init(BeanInfo.java:508)
		at io.quarkus.arc.processor.BeanDeployment.init(BeanDeployment.java:257)
		... 13 more
	Suppressed: javax.enterprise.inject.UnsatisfiedResolutionException: Unsatisfied dependency for type org.apache.camel.CamelContext and qualifiers [@Default]
	- java member: io.smallrye.reactive.messaging.camel.CamelConnector#camel
	- declared on CLASS bean [types=[org.eclipse.microprofile.reactive.messaging.spi.ConnectorFactory, org.eclipse.microprofile.reactive.messaging.spi.OutgoingConnectorFactory, io.smallrye.reactive.messaging.camel.CamelConnector, org.eclipse.microprofile.reactive.messaging.spi.IncomingConnectorFactory, java.lang.Object], qualifiers=[@Connector(value = "smallrye-camel"), @Any], target=io.smallrye.reactive.messaging.camel.CamelConnector]
		at io.quarkus.arc.processor.Beans.resolveInjectionPoint(Beans.java:428)
		at io.quarkus.arc.processor.BeanInfo.init(BeanInfo.java:508)
		at io.quarkus.arc.processor.BeanDeployment.init(BeanDeployment.java:257)
		... 13 more

@jamesnetherton
Copy link
Contributor

I opened a pull request on your project fix up the dependencies https://github.com/freedev/code-with-quarkus-camel/pull/1.

That should allow the app to launch at least.

Note that there is no Camel Quarkus extension for camel-azure-servicebus yet. So its not guaranteed to work 100% correctly if you just refer to the plain Camel component dependency, especially if you expect native mode support for it. See also #3386.

@freedev
Copy link
Author

freedev commented Jan 20, 2022

Hi thanks for helping, your pull request did the job.
What about add a azure service bus integration sample in https://github.com/smallrye/smallrye-reactive-messaging/tree/main/examples or even in https://github.com/apache/camel-quarkus-examples
Can I try a pull request?

@freedev freedev closed this as completed Jan 20, 2022
@jamesnetherton
Copy link
Contributor

I'd wait for #3386 to be fixed before contributing an example based on camel-azure-servicebus.

@freedev
Copy link
Author

freedev commented Jan 20, 2022 •
edited

I just had a look at #3386 but it's not clear what's missing part, well, apart the title.
Anyway, I've just updated https://github.com/freedev/code-with-quarkus-camel adding a proper README that explain how to do it.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Assignees
No one assigned
Labels
None yet
Projects
None yet
Milestone
No milestone
Development

No branches or pull requests
2 participants
@freedev @jamesnetherton