JiriOndrusek opened a new issue, #3944: URL: https://github.com/apache/camel-quarkus/issues/3944
The original test was sending **6** messages and receives them afterwards. In CLI there was a failure (without any obvious reason) with the 3rd message. Here is a log snippet: ``` ... 2022-07-27T13:37:14.9553433Z 2022-07-27 13:37:14,950 TRACE [org.apa.cam.imp.eng.DefaultReactiveExecutor] (executor-thread-0) Worker #1 running: SimpleTask 2022-07-27T13:37:14.9554222Z 2022-07-27 13:37:14,950 INFO [route2] (executor-thread-0) Header was set, sending to google-pubsub:test-project:camel-quarkus-ordering-topic-pi2fxalq2829cdv2ewyw6ezh6aiinebubvrvadslegqfy9xvh 2022-07-27T13:37:14.9555185Z 2022-07-27 13:37:14,950 TRACE [org.apa.cam.imp.eng.DefaultReactiveExecutor] (executor-thread-0) Schedule [first=false, main=false, sync=false]: org.apache.camel.impl.engine.CamelInternalProcessor$AsyncAfterTask@73b7e456 2022-07-27T13:37:14.9556102Z 2022-07-27 13:37:14,950 TRACE [org.apa.cam.imp.eng.DefaultReactiveExecutor] (executor-thread-0) Queuing reactive work: org.apache.camel.impl.engine.CamelInternalProcessor$AsyncAfterTask@73b7e456 2022-07-27T13:37:14.9556968Z 2022-07-27 13:37:14,950 TRACE [org.apa.cam.imp.eng.DefaultReactiveExecutor] (executor-thread-0) Worker #1 running: org.apache.camel.impl.engine.CamelInternalProcessor$AsyncAfterTask@73b7e456 2022-07-27T13:37:14.9557828Z 2022-07-27 13:37:14,950 TRACE [org.apa.cam.imp.eng.DefaultReactiveExecutor] (executor-thread-0) Schedule [first=false, main=false, sync=false]: org.apache.camel.processor.Pipeline$PipelineTask@566bdc6b 2022-07-27T13:37:14.9558295Z 2022-07-27 13:37:14,950 TRACE [org.apa.cam.imp.eng.DefaultReactiveExecutor] (executor-thread-0) Queuing reactive work: org.apache.camel.processor.Pipeline$PipelineTask@566bdc6b 2022-07-27T13:37:14.9558745Z 2022-07-27 13:37:14,950 TRACE [org.apa.cam.imp.eng.DefaultReactiveExecutor] (executor-thread-0) Worker #1 running: org.apache.camel.processor.Pipeline$PipelineTask@566bdc6b 2022-07-27T13:37:14.9559234Z 2022-07-27 13:37:14,950 TRACE [org.apa.cam.imp.con.CoreTypeConverterRegistry] (executor-thread-0) Finding type converter to convert java.lang.String -> org.apache.camel.StreamCache with value: 3 2022-07-27T13:37:14.9559858Z 2022-07-27 13:37:14,950 TRACE [org.apa.cam.imp.con.CoreTypeConverterRegistry] (executor-thread-0) Using bulk converter: CamelBaseBulkConverterLoader to convert [class java.lang.String=>interface org.apache.camel.StreamCache] 2022-07-27T13:37:14.9560418Z 2022-07-27 13:37:14,950 TRACE [org.apa.cam.imp.con.CoreTypeConverterRegistry] (executor-thread-0) Using bulk converter: StreamCacheBulkConverterLoader to convert [class java.lang.String=>interface org.apache.camel.StreamCache] 2022-07-27T13:37:14.9561078Z 2022-07-27 13:37:14,950 TRACE [org.apa.cam.imp.con.CoreTypeConverterRegistry] (executor-thread-0) Using converter: org.apache.camel.impl.converter.CoreTypeConverterRegistry$1@21fefb31 to convert [class java.lang.String=>interface org.apache.camel.StreamCache] 2022-07-27T13:37:14.9561573Z 2022-07-27 13:37:14,950 TRACE [org.apa.cam.imp.eng.CamelInternalProcessor] (executor-thread-0) Processing exchange for exchangeId: 64C35E7D9B618FD-0000000000000008 -> Exchange[64C35E7D9B618FD-0000000000000008] 2022-07-27T13:37:14.9561968Z 2022-07-27 13:37:14,950 TRACE [org.apa.cam.imp.eng.DefaultReactiveExecutor] (executor-thread-0) Schedule [first=true, main=true, sync=false]: SimpleTask 2022-07-27T13:37:14.9562321Z 2022-07-27 13:37:14,950 TRACE [org.apa.cam.imp.eng.DefaultReactiveExecutor] (executor-thread-0) Queuing reactive work: SimpleTask 2022-07-27T13:37:14.9562886Z 2022-07-27 13:37:14,950 TRACE [org.apa.cam.imp.eng.CamelInternalProcessor] (executor-thread-0) Exchange processed and is continued routed asynchronously for exchangeId: 64C35E7D9B618FD-0000000000000008 -> Exchange[64C35E7D9B618FD-0000000000000008] 2022-07-27T13:37:14.9563272Z 2022-07-27 13:37:14,950 TRACE [org.apa.cam.imp.eng.DefaultReactiveExecutor] (executor-thread-0) Worker #1 running: SimpleTask 2022-07-27T13:37:14.9564237Z 2022-07-27 13:37:14,950 TRACE [org.apa.cam.sup.EventHelper] (executor-thread-0) Notifier: org.apache.camel.main.BaseMainSupport$1@6a1b4854 is not enabled for the event: 64C35E7D9B618FD-0000000000000008 exchange sending to: google-pubsub://test-project:camel-quarkus-ordering-topic-pi2fxalq2829cdv2ewyw6ezh6aiinebubvrvadslegqfy9xvh?messageOrderingEnabled=true 2022-07-27T13:37:14.9565018Z 2022-07-27 13:37:14,950 DEBUG [org.apa.cam.pro.SendProcessor] (executor-thread-0) >>>> google-pubsub://test-project:camel-quarkus-ordering-topic-pi2fxalq2829cdv2ewyw6ezh6aiinebubvrvadslegqfy9xvh?messageOrderingEnabled=true Exchange[64C35E7D9B618FD-0000000000000008] 2022-07-27T13:37:14.9565463Z 2022-07-27 13:37:14,950 DEBUG [org.apa.cam.com.goo.pub.GooglePubsubProducer] (executor-thread-0) uploader thread/id: 126 / 64C35E7D9B618FD-0000000000000008. api call completed. 2022-07-27T13:37:14.9565962Z 2022-07-27 13:37:14,950 TRACE [org.apa.cam.pro.err.RedeliveryErrorHandler] (executor-thread-0) This exchange is not handled or continued so its marked as failed: Exchange[64C35E7D9B618FD-0000000000000008] 2022-07-27T13:37:14.9566895Z 2022-07-27 13:37:14,953 ERROR [org.apa.cam.pro.err.DefaultErrorHandler] (executor-thread-0) Failed delivery for (MessageId: 64C35E7D9B618FD-0000000000000008 on ExchangeId: 64C35E7D9B618FD-0000000000000008). Exhausted after delivery attempt: 1 caught: java.util.concurrent.ExecutionException: java.util.concurrent.CancellationException: Execution cancelled because executing previous runnable failed. ``` The current test sends **2** messages and then receive them in the right order. To simulate an error (in CLI), duplicate the code to send and receive **6** messages. One of the feasible reason could be the memory and CPU limitation in CLI - I used some limitations locally, but I was not able to simulate the failure. -- 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. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
