KMUS opened a new issue #2632:
URL: https://github.com/apache/camel-quarkus/issues/2632


   Declaring a class with @Consume annotation always fails. See below for 
complete error message. An other issue I want to point out is, a missing 
@Inject on @Produce("direct:startHere") results in a npe.
   
   I am grateful for any help.
   
   Main.class
   ```
   public class Main implements QuarkusApplication {
   
       @Inject
       CamelStarter starter;
   
       @Override
       public int run(String... args) throws Exception {
           starter.run();
           return 0;
       }
   
       public static void main(String[] args) {
           Quarkus.run(Main.class, args);
       }
   }
   ```
   
   CamelStarter .class
   ```
   @Dependent
   public class CamelStarter {
   
       @Inject
       @Produce("direct:startHere")
       ProducerTemplate producer;
   
       public void run() {
           producer.sendBody("ApacheCamel");
           Quarkus.waitForExit();
       }
   
   }
   ```
   
   CamelRoutes .class
   ```
   @ApplicationScoped
   public class CamelRoutes extends RouteBuilder {
   
       @Override
       public void configure() {
           from("direct:startHere")
                   .to("direct:bar");
       }
   }
   ```
   
   Bar.class
   ```
   public class Bar {
   
       @Consume("direct:bar")
       public void onBar(String str) {
           System.out.println("onBar: " + str);
       }
   }
   ```
   
   ```
   [org.apa.cam.qua.cor.CamelBootstrapRecorder] (Quarkus Main Thread) bootstrap 
runtime: org.apache.camel.quarkus.main.CamelMainRuntime
   [org.apa.cam.imp.eng.AbstractCamelContext] (Quarkus Main Thread) Routes 
startup summary (total:1 started:1)
   [org.apa.cam.imp.eng.AbstractCamelContext] (Quarkus Main Thread) Started 
route1 (direct://startHere)
   [org.apa.cam.imp.eng.AbstractCamelContext] (Quarkus Main Thread) Apache 
Camel 3.9.0 (camel-1) started in 54ms (build:0ms init:38ms start:16ms)
   [io.quarkus] (Quarkus Main Thread) Quarkus 1.13.4.Final on JVM started in 
1.792s. 
   [io.quarkus] (Quarkus Main Thread) Profile dev activated. Live Coding 
activated.
   [io.quarkus] (Quarkus Main Thread) Installed features: [camel-bean, 
camel-core, camel-direct, camel-file, camel-log, camel-support-common, 
camel-timer, cdi, picocli]
   ```
   
   ```
   org.apache.camel.component.direct.DirectConsumerNotAvailableException: No 
consumers available on endpoint: direct://bar. Exchange[]
   
   Message History (complete message history is disabled)
   
---------------------------------------------------------------------------------------------------------------------------------------
   RouteId              ProcessorId          Processor                          
                                              Elapsed (ms)
   [route1            ] [route1            ] [from[direct://startHere]          
                                            ] [     30006]
        ...
   [route1            ] [to1               ] [direct:bar                        
                                            ] [         0]
   
   Stacktrace
   
---------------------------------------------------------------------------------------------------------------------------------------
   : org.apache.camel.component.direct.DirectConsumerNotAvailableException: No 
consumers available on endpoint: direct://bar. Exchange[]
        at 
org.apache.camel.component.direct.DirectProducer.process(DirectProducer.java:82)
        at 
org.apache.camel.processor.SendProcessor.process(SendProcessor.java:172)
        at 
org.apache.camel.processor.errorhandler.RedeliveryErrorHandler$SimpleTask.run(RedeliveryErrorHandler.java:439)
        at 
org.apache.camel.impl.engine.DefaultReactiveExecutor$Worker.schedule(DefaultReactiveExecutor.java:181)
        at 
org.apache.camel.impl.engine.DefaultReactiveExecutor.scheduleMain(DefaultReactiveExecutor.java:62)
        at org.apache.camel.processor.Pipeline.process(Pipeline.java:167)
        at 
org.apache.camel.impl.engine.CamelInternalProcessor.process(CamelInternalProcessor.java:388)
        at 
org.apache.camel.component.direct.DirectProducer.process(DirectProducer.java:96)
        at 
org.apache.camel.impl.engine.SharedCamelInternalProcessor.process(SharedCamelInternalProcessor.java:217)
        at 
org.apache.camel.impl.engine.SharedCamelInternalProcessor$1.process(SharedCamelInternalProcessor.java:111)
        at 
org.apache.camel.impl.engine.DefaultAsyncProcessorAwaitManager.process(DefaultAsyncProcessorAwaitManager.java:83)
        at 
org.apache.camel.impl.engine.SharedCamelInternalProcessor.process(SharedCamelInternalProcessor.java:108)
        at 
org.apache.camel.support.cache.DefaultProducerCache.send(DefaultProducerCache.java:190)
        at 
org.apache.camel.impl.engine.DefaultProducerTemplate.send(DefaultProducerTemplate.java:176)
        at 
org.apache.camel.impl.engine.DefaultProducerTemplate.send(DefaultProducerTemplate.java:172)
        at 
org.apache.camel.impl.engine.DefaultProducerTemplate.send(DefaultProducerTemplate.java:153)
        at 
org.apache.camel.impl.engine.DefaultProducerTemplate.sendBody(DefaultProducerTemplate.java:187)
        at 
org.apache.camel.impl.engine.DefaultProducerTemplate.sendBody(DefaultProducerTemplate.java:457)
        at x.y.CamelStarter.run(CamelStarter.java:21)
        at 
x.y.CamelStarter_Subclass.run$$superaccessor1(CamelStarter_Subclass.zig:189)
        at 
x.y.CamelStarter_Subclass$$function$$1.apply(CamelStarter_Subclass$$function$$1.zig:29)
        at 
io.quarkus.arc.impl.AroundInvokeInvocationContext.proceed(AroundInvokeInvocationContext.java:54)
        at 
io.quarkus.arc.runtime.devconsole.InvocationInterceptor.proceed(InvocationInterceptor.java:63)
        at 
io.quarkus.arc.runtime.devconsole.InvocationInterceptor.monitor(InvocationInterceptor.java:51)
        at 
io.quarkus.arc.runtime.devconsole.InvocationInterceptor_Bean.intercept(InvocationInterceptor_Bean.zig:521)
        at 
io.quarkus.arc.impl.InterceptorInvocation.invoke(InterceptorInvocation.java:41)
        at 
io.quarkus.arc.impl.AroundInvokeInvocationContext.perform(AroundInvokeInvocationContext.java:41)
        at 
io.quarkus.arc.impl.InvocationContexts.performAroundInvoke(InvocationContexts.java:32)
        at x.y.CamelStarter_Subclass.run(CamelStarter_Subclass.zig:147)
        at x.y.Main.run(Main.java:18)
        at x.y.Main_ClientProxy.run(Main_ClientProxy.zig:129)
        at 
io.quarkus.runtime.ApplicationLifecycleManager.run(ApplicationLifecycleManager.java:122)
        at io.quarkus.runtime.Quarkus.run(Quarkus.java:66)
        at io.quarkus.runtime.Quarkus.run(Quarkus.java:42)
        at x.y.Main.main(Main.java:23)
        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.runner.bootstrap.StartupActionImpl$3.run(StartupActionImpl.java:134)
        at java.base/java.lang.Thread.run(Thread.java:834)
   
   2021-05-19 19:01:59,428 ERROR [io.qua.run.Application] (Quarkus Main Thread) 
Failed to start application (with profile dev): 
org.apache.camel.component.direct.DirectConsumerNotAvailableException: No 
consumers available on endpoint: direct://bar. Exchange[]
        at 
org.apache.camel.component.direct.DirectProducer.process(DirectProducer.java:82)
        at 
org.apache.camel.processor.SendProcessor.process(SendProcessor.java:172)
        at 
org.apache.camel.processor.errorhandler.RedeliveryErrorHandler$SimpleTask.run(RedeliveryErrorHandler.java:439)
        at 
org.apache.camel.impl.engine.DefaultReactiveExecutor$Worker.schedule(DefaultReactiveExecutor.java:181)
        at 
org.apache.camel.impl.engine.DefaultReactiveExecutor.scheduleMain(DefaultReactiveExecutor.java:62)
        at org.apache.camel.processor.Pipeline.process(Pipeline.java:167)
        at 
org.apache.camel.impl.engine.CamelInternalProcessor.process(CamelInternalProcessor.java:388)
        at 
org.apache.camel.component.direct.DirectProducer.process(DirectProducer.java:96)
        at 
org.apache.camel.impl.engine.SharedCamelInternalProcessor.process(SharedCamelInternalProcessor.java:217)
        at 
org.apache.camel.impl.engine.SharedCamelInternalProcessor$1.process(SharedCamelInternalProcessor.java:111)
        at 
org.apache.camel.impl.engine.DefaultAsyncProcessorAwaitManager.process(DefaultAsyncProcessorAwaitManager.java:83)
        at 
org.apache.camel.impl.engine.SharedCamelInternalProcessor.process(SharedCamelInternalProcessor.java:108)
        at 
org.apache.camel.support.cache.DefaultProducerCache.send(DefaultProducerCache.java:190)
        at 
org.apache.camel.impl.engine.DefaultProducerTemplate.send(DefaultProducerTemplate.java:176)
        at 
org.apache.camel.impl.engine.DefaultProducerTemplate.send(DefaultProducerTemplate.java:172)
        at 
org.apache.camel.impl.engine.DefaultProducerTemplate.send(DefaultProducerTemplate.java:153)
        at 
org.apache.camel.impl.engine.DefaultProducerTemplate.sendBody(DefaultProducerTemplate.java:187)
        at 
org.apache.camel.impl.engine.DefaultProducerTemplate.sendBody(DefaultProducerTemplate.java:457)
        at x.y.CamelStarter.run(CamelStarter.java:21)
        at 
x.y.CamelStarter_Subclass.run$$superaccessor1(CamelStarter_Subclass.zig:189)
        at 
x.y.CamelStarter_Subclass$$function$$1.apply(CamelStarter_Subclass$$function$$1.zig:29)
        at 
io.quarkus.arc.impl.AroundInvokeInvocationContext.proceed(AroundInvokeInvocationContext.java:54)
        at 
io.quarkus.arc.runtime.devconsole.InvocationInterceptor.proceed(InvocationInterceptor.java:63)
        at 
io.quarkus.arc.runtime.devconsole.InvocationInterceptor.monitor(InvocationInterceptor.java:51)
        at 
io.quarkus.arc.runtime.devconsole.InvocationInterceptor_Bean.intercept(InvocationInterceptor_Bean.zig:521)
        at 
io.quarkus.arc.impl.InterceptorInvocation.invoke(InterceptorInvocation.java:41)
        at 
io.quarkus.arc.impl.AroundInvokeInvocationContext.perform(AroundInvokeInvocationContext.java:41)
        at 
io.quarkus.arc.impl.InvocationContexts.performAroundInvoke(InvocationContexts.java:32)
        at x.y.CamelStarter_Subclass.run(CamelStarter_Subclass.zig:147)
        at x.y.Main.run(Main.java:18)
        at x.y.Main_ClientProxy.run(Main_ClientProxy.zig:129)
        at 
io.quarkus.runtime.ApplicationLifecycleManager.run(ApplicationLifecycleManager.java:122)
        at io.quarkus.runtime.Quarkus.run(Quarkus.java:66)
        at io.quarkus.runtime.Quarkus.run(Quarkus.java:42)
        at x.y.Main.main(Main.java:23)
        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.runner.bootstrap.StartupActionImpl$3.run(StartupActionImpl.java:134)
        at java.base/java.lang.Thread.run(Thread.java:834)
   
   2021-05-19 19:01:59,428 INFO  [org.apa.cam.imp.eng.AbstractCamelContext] 
(Quarkus Main Thread) Apache Camel 3.9.0 (camel-1) shutting down
   2021-05-19 19:01:59,428 INFO  [org.apa.cam.imp.eng.AbstractCamelContext] 
(Quarkus Main Thread) Routes shutdown summary (total:1 stopped:1)
   2021-05-19 19:01:59,428 INFO  [org.apa.cam.imp.eng.AbstractCamelContext] 
(Quarkus Main Thread)     Stopped route1 (direct://startHere)
   2021-05-19 19:01:59,428 INFO  [org.apa.cam.imp.eng.AbstractCamelContext] 
(Quarkus Main Thread) Apache Camel 3.9.0 (camel-1) shutdown in 0ms 
(uptime:30s42ms)
   2021-05-19 19:01:59,476 INFO  [io.quarkus] (Quarkus Main Thread) Quarkus 
stopped in 0.053s
   ```


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Reply via email to