nicolaferraro opened a new issue #500:
URL: https://github.com/apache/camel-k-runtime/issues/500


   Trying this kamelet:
   
   ```yaml
   apiVersion: camel.apache.org/v1alpha1
   kind: Kamelet
   metadata:
     name: echo-sink
     label:
       camel.apache.org/kamelet.type: "sink"
   spec:
     definition:
       title: "Echo"
       description: "Replies with an echo message to each incoming event"
       properties:
         prefix:
           title: Prefix
           description: The prefix to prepend to the incoming event
           type: string
           default: "echo: "
     types:
       in:
         mediaType: text/plain
       out:
         mediaType: text/plain
     flow:
       from:
         uri: "direct:#property:routeId"
         steps:
           - log: "Called Kamelet"
           - set-body:
               simple: "#property:prefix${body}"
   ```
   
   Using that from an integratino like:
   
    ```groovy
   from('timer:tick')
     .setBody().constant('Hello 2')
     .log("calling kamelet ...")
     .to("kamelet:echo-sink")
     .log('${body}')
   
   ```
   
   From the logs, it does not seem the Kamelet to be called. It's printing 
"calling kamelet ...", then:
   
   ```
   source-sink-5bc9b7d645-ts9ds integration 2020-09-23 10:04:57,679 WARN  
[org.apa.cam.com.tim.TimerConsumer] (Camel (camel-1) thread #0 - timer://tick) 
Error processing exchange. Exchange[840B1B4EC9BE9A7-0000000000000006]. Caused 
by: [org.apache.camel.component.direct.DirectConsumerNotAvailableException - No 
consumers available on endpoint: 
direct://echo-sink-840B1B4EC9BE9A7-0000000000000000. Exchange[]]: 
org.apache.camel.component.direct.DirectConsumerNotAvailableException: No 
consumers available on endpoint: 
direct://echo-sink-840B1B4EC9BE9A7-0000000000000000. Exchange[]
   source-sink-5bc9b7d645-ts9ds integration        at 
org.apache.camel.component.direct.DirectProducer.process(DirectProducer.java:59)
   source-sink-5bc9b7d645-ts9ds integration        at 
org.apache.camel.component.kamelet.KameletEndpoint$KameletProducer.process(KameletEndpoint.java:158)
   source-sink-5bc9b7d645-ts9ds integration        at 
org.apache.camel.processor.SendProcessor.process(SendProcessor.java:169)
   source-sink-5bc9b7d645-ts9ds integration        at 
org.apache.camel.processor.errorhandler.RedeliveryErrorHandler$SimpleTask.run(RedeliveryErrorHandler.java:404)
   source-sink-5bc9b7d645-ts9ds integration        at 
org.apache.camel.impl.engine.DefaultReactiveExecutor$Worker.schedule(DefaultReactiveExecutor.java:148)
   source-sink-5bc9b7d645-ts9ds integration        at 
org.apache.camel.impl.engine.DefaultReactiveExecutor.scheduleMain(DefaultReactiveExecutor.java:60)
   source-sink-5bc9b7d645-ts9ds integration        at 
org.apache.camel.processor.Pipeline.process(Pipeline.java:147)
   source-sink-5bc9b7d645-ts9ds integration        at 
org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:287)
   source-sink-5bc9b7d645-ts9ds integration        at 
org.apache.camel.component.timer.TimerConsumer.sendTimerExchange(TimerConsumer.java:207)
   source-sink-5bc9b7d645-ts9ds integration        at 
org.apache.camel.component.timer.TimerConsumer$1.run(TimerConsumer.java:76)
   source-sink-5bc9b7d645-ts9ds integration        at 
java.base/java.util.TimerThread.mainLoop(Timer.java:556)
   source-sink-5bc9b7d645-ts9ds integration        at 
java.base/java.util.TimerThread.run(Timer.java:506)
   
   ```
   


----------------------------------------------------------------
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