API tools faq
paste
Advertisement
rohankanojia

Camel Hazelcast Sample Build using Eclipse JKube OpenShift Maven Plugin Pod Logs

rohankanojia
Oct 27th, 2020
69
0
Never
Add comment
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
Bash 52.05 KB | None | 0 0
raw download clone embed print report
  1. camel-example-hazelcast-kubernetes : $ oc get pods
  2. NAME                                             READY     STATUS      RESTARTS   AGE
  3. camel-example-hazelcast-kubernetes-1-b6h5t       1/1       Running     0          115s
  4. camel-example-hazelcast-kubernetes-1-deploy      0/1       Completed   0          118s
  5. camel-example-hazelcast-kubernetes-s2i-1-build   0/1       Completed   0          2m59s
  6. hazelcast-84cc546755-w4lwc                       1/1       Running     0          119s
  7. camel-example-hazelcast-kubernetes : $ oc logs pod/camel-example-hazelcast-kubernetes-1-b6h5t
  8. Starting the Java application using /opt/jboss/container/java/run/run-java.sh ...
  9. INFO exec  java -javaagent:/usr/share/java/jolokia-jvm-agent/jolokia-jvm.jar=config=/opt/jboss/container/jolokia/etc/jolokia.properties -javaagent:/usr/share/java/prometheus-jmx-exporter/jmx_prometheus_javaagent.jar=9779:/opt/jboss/container/prometheus/etc/jmx-exporter-config.yaml -XX:+UseParallelOldGC -XX:MinHeapFreeRatio=10 -XX:MaxHeapFreeRatio=20 -XX:GCTimeRatio=4 -XX:AdaptiveSizePolicyWeight=90 -XX:MaxMetaspaceSize=100m -XX:+ExitOnOutOfMemoryError -cp "." -jar /deployments/camel-example-hazelcast-kubernetes-3.7.0-SNAPSHOT.jar  
  10. WARNING: An illegal reflective access operation has occurred
  11. WARNING: Illegal reflective access by org.jolokia.util.ClassUtil (file:/usr/share/java/jolokia-jvm-agent/jolokia-jvm.jar) to constructor sun.security.x509.X500Name(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String)
  12. WARNING: Please consider reporting this to the maintainers of org.jolokia.util.ClassUtil
  13. WARNING: Use --illegal-access=warn to enable warnings of further illegal reflective access operations
  14. WARNING: All illegal access operations will be denied in a future release
  15. I> No access restrictor found, access to any MBean is allowed
  16. Jolokia: Agent started with URL https://10.116.0.71:8778/jolokia/
  17. 2020-10-27 16:03:29,613 [main           ] INFO  LRUCacheFactory                - Detected and using LRUCacheFactory: camel-caffeine-lrucache
  18. Oct 27, 2020 4:03:31 PM com.hazelcast.client.impl.spi.ClientInvocationService
  19. INFO: hz.client_1 [dev] [4.0.3] Running with 2 response threads, dynamic=true
  20. Oct 27, 2020 4:03:31 PM com.hazelcast.core.LifecycleService
  21. INFO: hz.client_1 [dev] [4.0.3] HazelcastClient 4.0.3 (20200921 - 59ae831) is STARTING
  22. Oct 27, 2020 4:03:31 PM com.hazelcast.core.LifecycleService
  23. INFO: hz.client_1 [dev] [4.0.3] HazelcastClient 4.0.3 (20200921 - 59ae831) is STARTED
  24. Oct 27, 2020 4:03:31 PM com.hazelcast.client.impl.connection.ClientConnectionManager
  25. INFO: hz.client_1 [dev] [4.0.3] Trying to connect to cluster: dev
  26. Oct 27, 2020 4:03:31 PM com.hazelcast.client.impl.connection.ClientConnectionManager
  27. INFO: hz.client_1 [dev] [4.0.3] Trying to connect to [hazelcast]:5701
  28. Oct 27, 2020 4:03:33 PM com.hazelcast.core.LifecycleService
  29. INFO: hz.client_1 [dev] [4.0.3] HazelcastClient 4.0.3 (20200921 - 59ae831) is CLIENT_CONNECTED
  30. Oct 27, 2020 4:03:33 PM com.hazelcast.client.impl.connection.ClientConnectionManager
  31. INFO: hz.client_1 [dev] [4.0.3] Authenticated with server [10.116.0.69]:5701:d0e6e171-3c6a-4ea6-abdc-5315a98219b0, server version: 4.0.3, local address: /10.116.0.71:54011
  32. Oct 27, 2020 4:03:33 PM com.hazelcast.internal.diagnostics.Diagnostics
  33. INFO: hz.client_1 [dev] [4.0.3] Diagnostics disabled. To enable add -Dhazelcast.diagnostics.enabled=true to the JVM arguments.
  34. Oct 27, 2020 4:03:33 PM com.hazelcast.client.impl.spi.ClientClusterService
  35. INFO: hz.client_1 [dev] [4.0.3]
  36.  
  37. Members [1] {
  38.     Member [10.116.0.69]:5701 - d0e6e171-3c6a-4ea6-abdc-5315a98219b0
  39. }
  40.  
  41. Oct 27, 2020 4:03:34 PM com.hazelcast.client.impl.statistics.ClientStatisticsService
  42. INFO: Client statistics is enabled with period 5 seconds.
  43. 2020-10-27 16:03:34,819 [main           ] INFO  AbstractCamelContext           - Apache Camel 3.7.0-SNAPSHOT (camel-1) is starting
  44. 2020-10-27 16:03:34,824 [main           ] INFO  AbstractCamelContext           - StreamCaching is not in use. If using streams then its recommended to enable stream caching. See more details at http://camel.apache.org/stream-caching.html
  45. 2020-10-27 16:03:34,865 [main           ] INFO  InternalRouteStartupManager    - Route: route1 started and consuming from: timer://foo
  46. 2020-10-27 16:03:34,867 [main           ] INFO  InternalRouteStartupManager    - Route: route2 started and consuming from: hazelcast-topic://foo
  47. 2020-10-27 16:03:34,868 [main           ] INFO  AbstractCamelContext           - Total 2 routes, of which 2 are started
  48. 2020-10-27 16:03:34,868 [main           ] INFO  AbstractCamelContext           - Apache Camel 3.7.0-SNAPSHOT (camel-1) started in 0.049 seconds
  49. 2020-10-27 16:03:34,885 [main           ] INFO  BaseMainSupport                - Using properties from: classpath:application.properties;optional=true
  50. 2020-10-27 16:03:34,914 [main           ] INFO  DefaultShutdownStrategy        - Starting to graceful shutdown 1 routes (timeout 45 seconds)
  51. 2020-10-27 16:03:34,918 [ - ShutdownTask] INFO  DefaultShutdownStrategy        - Route: route1 shutdown complete, was consuming from: timer://foo
  52. 2020-10-27 16:03:34,919 [main           ] INFO  DefaultShutdownStrategy        - Graceful shutdown of 1 routes completed in 0 seconds
  53. 2020-10-27 16:03:34,920 [main           ] INFO  AbstractCamelContext           - Route: route1 is stopped, was consuming from: timer://foo
  54. 2020-10-27 16:03:34,924 [main           ] INFO  AbstractCamelContext           - Route: route1 is shutdown and removed, was consuming from: timer://foo
  55. 2020-10-27 16:03:34,926 [main           ] INFO  DefaultShutdownStrategy        - Starting to graceful shutdown 1 routes (timeout 45 seconds)
  56. 2020-10-27 16:03:34,926 [ - ShutdownTask] INFO  DefaultShutdownStrategy        - Route: route2 shutdown complete, was consuming from: hazelcast-topic://foo
  57. 2020-10-27 16:03:34,926 [main           ] INFO  DefaultShutdownStrategy        - Graceful shutdown of 1 routes completed in 0 seconds
  58. 2020-10-27 16:03:34,936 [main           ] INFO  AbstractCamelContext           - Route: route2 is stopped, was consuming from: hazelcast-topic://foo
  59. 2020-10-27 16:03:34,937 [main           ] INFO  AbstractCamelContext           - Route: route2 is shutdown and removed, was consuming from: hazelcast-topic://foo
  60. 2020-10-27 16:03:34,944 [main           ] INFO  InternalRouteStartupManager    - Route: route1 started and consuming from: timer://foo
  61. 2020-10-27 16:03:34,976 [main           ] INFO  InternalRouteStartupManager    - Route: route2 started and consuming from: hazelcast-topic://foo
  62. 2020-10-27 16:03:34,988 [main           ] INFO  DefaultRoutesCollector         - No additional Camel XML routes discovered from: classpath:camel/*.xml
  63. 2020-10-27 16:03:34,989 [main           ] INFO  DefaultRoutesCollector         - No additional Camel XML route templates discovered from: classpath:camel-template/*.xml
  64. 2020-10-27 16:03:34,989 [main           ] INFO  DefaultRoutesCollector         - No additional Camel XML rests discovered from: classpath:camel-rest/*.xml
  65. 2020-10-27 16:03:35,967 [3 - timer://foo] INFO  route1                         - Producer side: Sending data to Hazelcast topic..
  66. 2020-10-27 16:03:35,997 [lient_1.event-3] INFO  route2                         - Consumer side: Detected following action: received
  67. 2020-10-27 16:03:36,012 [lient_1.event-3] WARN  HazelcastTopicConsumer         - Error processing exchange for hazelcast consumer on object 'null' in cache 'foo'.. Exchange[]. Caused by: [java.util.concurrent.RejectedExecutionException - null]
  68. java.util.concurrent.RejectedExecutionException
  69.     at org.apache.camel.processor.errorhandler.RedeliveryErrorHandler$SimpleTask.run(RedeliveryErrorHandler.java:381)
  70.     at org.apache.camel.impl.engine.DefaultReactiveExecutor$Worker.schedule(DefaultReactiveExecutor.java:148)
  71.     at org.apache.camel.impl.engine.DefaultReactiveExecutor.scheduleMain(DefaultReactiveExecutor.java:60)
  72.     at org.apache.camel.processor.Pipeline.process(Pipeline.java:147)
  73.     at org.apache.camel.impl.engine.CamelInternalProcessor.process(CamelInternalProcessor.java:312)
  74.     at org.apache.camel.impl.engine.DefaultAsyncProcessorAwaitManager.process(DefaultAsyncProcessorAwaitManager.java:83)
  75.     at org.apache.camel.support.AsyncProcessorSupport.process(AsyncProcessorSupport.java:41)
  76.     at org.apache.camel.component.hazelcast.listener.CamelListener.sendExchange(CamelListener.java:48)
  77.     at org.apache.camel.component.hazelcast.listener.CamelMessageListener.onMessage(CamelMessageListener.java:35)
  78.     at com.hazelcast.client.impl.proxy.ClientTopicProxy$TopicItemHandler.handleTopicEvent(ClientTopicProxy.java:97)
  79.     at com.hazelcast.client.impl.protocol.codec.TopicAddMessageListenerCodec$AbstractEventHandler.handle(TopicAddMessageListenerCodec.java:147)
  80.     at com.hazelcast.client.impl.proxy.ClientTopicProxy$TopicItemHandler.handle(ClientTopicProxy.java:85)
  81.     at com.hazelcast.client.impl.spi.impl.listener.ClientListenerServiceImpl.handleEventMessageOnCallingThread(ClientListenerServiceImpl.java:185)
  82.     at com.hazelcast.client.impl.spi.impl.listener.ClientListenerServiceImpl$ClientEventProcessor.run(ClientListenerServiceImpl.java:354)
  83.     at com.hazelcast.internal.util.executor.StripedExecutor$Worker.process(StripedExecutor.java:245)
  84.     at com.hazelcast.internal.util.executor.StripedExecutor$Worker.run(StripedExecutor.java:228)
  85. 2020-10-27 16:03:40,946 [3 - timer://foo] INFO  route1                         - Producer side: Sending data to Hazelcast topic..
  86. 2020-10-27 16:03:40,951 [lient_1.event-3] INFO  route2                         - Consumer side: Detected following action: received
  87. 2020-10-27 16:03:40,952 [lient_1.event-3] WARN  HazelcastTopicConsumer         - Error processing exchange for hazelcast consumer on object 'null' in cache 'foo'.. Exchange[]. Caused by: [java.util.concurrent.RejectedExecutionException - null]
  88. java.util.concurrent.RejectedExecutionException
  89.     at org.apache.camel.processor.errorhandler.RedeliveryErrorHandler$SimpleTask.run(RedeliveryErrorHandler.java:381)
  90.     at org.apache.camel.impl.engine.DefaultReactiveExecutor$Worker.schedule(DefaultReactiveExecutor.java:148)
  91.     at org.apache.camel.impl.engine.DefaultReactiveExecutor.scheduleMain(DefaultReactiveExecutor.java:60)
  92.     at org.apache.camel.processor.Pipeline.process(Pipeline.java:147)
  93.     at org.apache.camel.impl.engine.CamelInternalProcessor.process(CamelInternalProcessor.java:312)
  94.     at org.apache.camel.impl.engine.DefaultAsyncProcessorAwaitManager.process(DefaultAsyncProcessorAwaitManager.java:83)
  95.     at org.apache.camel.support.AsyncProcessorSupport.process(AsyncProcessorSupport.java:41)
  96.     at org.apache.camel.component.hazelcast.listener.CamelListener.sendExchange(CamelListener.java:48)
  97.     at org.apache.camel.component.hazelcast.listener.CamelMessageListener.onMessage(CamelMessageListener.java:35)
  98.     at com.hazelcast.client.impl.proxy.ClientTopicProxy$TopicItemHandler.handleTopicEvent(ClientTopicProxy.java:97)
  99.     at com.hazelcast.client.impl.protocol.codec.TopicAddMessageListenerCodec$AbstractEventHandler.handle(TopicAddMessageListenerCodec.java:147)
  100.     at com.hazelcast.client.impl.proxy.ClientTopicProxy$TopicItemHandler.handle(ClientTopicProxy.java:85)
  101.     at com.hazelcast.client.impl.spi.impl.listener.ClientListenerServiceImpl.handleEventMessageOnCallingThread(ClientListenerServiceImpl.java:185)
  102.     at com.hazelcast.client.impl.spi.impl.listener.ClientListenerServiceImpl$ClientEventProcessor.run(ClientListenerServiceImpl.java:354)
  103.     at com.hazelcast.internal.util.executor.StripedExecutor$Worker.process(StripedExecutor.java:245)
  104.     at com.hazelcast.internal.util.executor.StripedExecutor$Worker.run(StripedExecutor.java:228)
  105. 2020-10-27 16:03:45,950 [3 - timer://foo] INFO  route1                         - Producer side: Sending data to Hazelcast topic..
  106. 2020-10-27 16:03:46,007 [lient_1.event-3] INFO  route2                         - Consumer side: Detected following action: received
  107. 2020-10-27 16:03:46,009 [lient_1.event-3] WARN  HazelcastTopicConsumer         - Error processing exchange for hazelcast consumer on object 'null' in cache 'foo'.. Exchange[]. Caused by: [java.util.concurrent.RejectedExecutionException - null]
  108. java.util.concurrent.RejectedExecutionException
  109.     at org.apache.camel.processor.errorhandler.RedeliveryErrorHandler$SimpleTask.run(RedeliveryErrorHandler.java:381)
  110.     at org.apache.camel.impl.engine.DefaultReactiveExecutor$Worker.schedule(DefaultReactiveExecutor.java:148)
  111.     at org.apache.camel.impl.engine.DefaultReactiveExecutor.scheduleMain(DefaultReactiveExecutor.java:60)
  112.     at org.apache.camel.processor.Pipeline.process(Pipeline.java:147)
  113.     at org.apache.camel.impl.engine.CamelInternalProcessor.process(CamelInternalProcessor.java:312)
  114.     at org.apache.camel.impl.engine.DefaultAsyncProcessorAwaitManager.process(DefaultAsyncProcessorAwaitManager.java:83)
  115.     at org.apache.camel.support.AsyncProcessorSupport.process(AsyncProcessorSupport.java:41)
  116.     at org.apache.camel.component.hazelcast.listener.CamelListener.sendExchange(CamelListener.java:48)
  117.     at org.apache.camel.component.hazelcast.listener.CamelMessageListener.onMessage(CamelMessageListener.java:35)
  118.     at com.hazelcast.client.impl.proxy.ClientTopicProxy$TopicItemHandler.handleTopicEvent(ClientTopicProxy.java:97)
  119.     at com.hazelcast.client.impl.protocol.codec.TopicAddMessageListenerCodec$AbstractEventHandler.handle(TopicAddMessageListenerCodec.java:147)
  120.     at com.hazelcast.client.impl.proxy.ClientTopicProxy$TopicItemHandler.handle(ClientTopicProxy.java:85)
  121.     at com.hazelcast.client.impl.spi.impl.listener.ClientListenerServiceImpl.handleEventMessageOnCallingThread(ClientListenerServiceImpl.java:185)
  122.     at com.hazelcast.client.impl.spi.impl.listener.ClientListenerServiceImpl$ClientEventProcessor.run(ClientListenerServiceImpl.java:354)
  123.     at com.hazelcast.internal.util.executor.StripedExecutor$Worker.process(StripedExecutor.java:245)
  124.     at com.hazelcast.internal.util.executor.StripedExecutor$Worker.run(StripedExecutor.java:228)
  125. 2020-10-27 16:03:50,951 [3 - timer://foo] INFO  route1                         - Producer side: Sending data to Hazelcast topic..
  126. 2020-10-27 16:03:50,971 [lient_1.event-3] INFO  route2                         - Consumer side: Detected following action: received
  127. 2020-10-27 16:03:50,972 [lient_1.event-3] WARN  HazelcastTopicConsumer         - Error processing exchange for hazelcast consumer on object 'null' in cache 'foo'.. Exchange[]. Caused by: [java.util.concurrent.RejectedExecutionException - null]
  128. java.util.concurrent.RejectedExecutionException
  129.     at org.apache.camel.processor.errorhandler.RedeliveryErrorHandler$SimpleTask.run(RedeliveryErrorHandler.java:381)
  130.     at org.apache.camel.impl.engine.DefaultReactiveExecutor$Worker.schedule(DefaultReactiveExecutor.java:148)
  131.     at org.apache.camel.impl.engine.DefaultReactiveExecutor.scheduleMain(DefaultReactiveExecutor.java:60)
  132.     at org.apache.camel.processor.Pipeline.process(Pipeline.java:147)
  133.     at org.apache.camel.impl.engine.CamelInternalProcessor.process(CamelInternalProcessor.java:312)
  134.     at org.apache.camel.impl.engine.DefaultAsyncProcessorAwaitManager.process(DefaultAsyncProcessorAwaitManager.java:83)
  135.     at org.apache.camel.support.AsyncProcessorSupport.process(AsyncProcessorSupport.java:41)
  136.     at org.apache.camel.component.hazelcast.listener.CamelListener.sendExchange(CamelListener.java:48)
  137.     at org.apache.camel.component.hazelcast.listener.CamelMessageListener.onMessage(CamelMessageListener.java:35)
  138.     at com.hazelcast.client.impl.proxy.ClientTopicProxy$TopicItemHandler.handleTopicEvent(ClientTopicProxy.java:97)
  139.     at com.hazelcast.client.impl.protocol.codec.TopicAddMessageListenerCodec$AbstractEventHandler.handle(TopicAddMessageListenerCodec.java:147)
  140.     at com.hazelcast.client.impl.proxy.ClientTopicProxy$TopicItemHandler.handle(ClientTopicProxy.java:85)
  141.     at com.hazelcast.client.impl.spi.impl.listener.ClientListenerServiceImpl.handleEventMessageOnCallingThread(ClientListenerServiceImpl.java:185)
  142.     at com.hazelcast.client.impl.spi.impl.listener.ClientListenerServiceImpl$ClientEventProcessor.run(ClientListenerServiceImpl.java:354)
  143.     at com.hazelcast.internal.util.executor.StripedExecutor$Worker.process(StripedExecutor.java:245)
  144.     at com.hazelcast.internal.util.executor.StripedExecutor$Worker.run(StripedExecutor.java:228)
  145. 2020-10-27 16:03:55,951 [3 - timer://foo] INFO  route1                         - Producer side: Sending data to Hazelcast topic..
  146. 2020-10-27 16:03:55,953 [lient_1.event-3] INFO  route2                         - Consumer side: Detected following action: received
  147. 2020-10-27 16:03:55,954 [lient_1.event-3] WARN  HazelcastTopicConsumer         - Error processing exchange for hazelcast consumer on object 'null' in cache 'foo'.. Exchange[]. Caused by: [java.util.concurrent.RejectedExecutionException - null]
  148. java.util.concurrent.RejectedExecutionException
  149.     at org.apache.camel.processor.errorhandler.RedeliveryErrorHandler$SimpleTask.run(RedeliveryErrorHandler.java:381)
  150.     at org.apache.camel.impl.engine.DefaultReactiveExecutor$Worker.schedule(DefaultReactiveExecutor.java:148)
  151.     at org.apache.camel.impl.engine.DefaultReactiveExecutor.scheduleMain(DefaultReactiveExecutor.java:60)
  152.     at org.apache.camel.processor.Pipeline.process(Pipeline.java:147)
  153.     at org.apache.camel.impl.engine.CamelInternalProcessor.process(CamelInternalProcessor.java:312)
  154.     at org.apache.camel.impl.engine.DefaultAsyncProcessorAwaitManager.process(DefaultAsyncProcessorAwaitManager.java:83)
  155.     at org.apache.camel.support.AsyncProcessorSupport.process(AsyncProcessorSupport.java:41)
  156.     at org.apache.camel.component.hazelcast.listener.CamelListener.sendExchange(CamelListener.java:48)
  157.     at org.apache.camel.component.hazelcast.listener.CamelMessageListener.onMessage(CamelMessageListener.java:35)
  158.     at com.hazelcast.client.impl.proxy.ClientTopicProxy$TopicItemHandler.handleTopicEvent(ClientTopicProxy.java:97)
  159.     at com.hazelcast.client.impl.protocol.codec.TopicAddMessageListenerCodec$AbstractEventHandler.handle(TopicAddMessageListenerCodec.java:147)
  160.     at com.hazelcast.client.impl.proxy.ClientTopicProxy$TopicItemHandler.handle(ClientTopicProxy.java:85)
  161.     at com.hazelcast.client.impl.spi.impl.listener.ClientListenerServiceImpl.handleEventMessageOnCallingThread(ClientListenerServiceImpl.java:185)
  162.     at com.hazelcast.client.impl.spi.impl.listener.ClientListenerServiceImpl$ClientEventProcessor.run(ClientListenerServiceImpl.java:354)
  163.     at com.hazelcast.internal.util.executor.StripedExecutor$Worker.process(StripedExecutor.java:245)
  164.     at com.hazelcast.internal.util.executor.StripedExecutor$Worker.run(StripedExecutor.java:228)
  165. 2020-10-27 16:04:00,952 [3 - timer://foo] INFO  route1                         - Producer side: Sending data to Hazelcast topic..
  166. 2020-10-27 16:04:00,956 [lient_1.event-3] INFO  route2                         - Consumer side: Detected following action: received
  167. 2020-10-27 16:04:00,957 [lient_1.event-3] WARN  HazelcastTopicConsumer         - Error processing exchange for hazelcast consumer on object 'null' in cache 'foo'.. Exchange[]. Caused by: [java.util.concurrent.RejectedExecutionException - null]
  168. java.util.concurrent.RejectedExecutionException
  169.     at org.apache.camel.processor.errorhandler.RedeliveryErrorHandler$SimpleTask.run(RedeliveryErrorHandler.java:381)
  170.     at org.apache.camel.impl.engine.DefaultReactiveExecutor$Worker.schedule(DefaultReactiveExecutor.java:148)
  171.     at org.apache.camel.impl.engine.DefaultReactiveExecutor.scheduleMain(DefaultReactiveExecutor.java:60)
  172.     at org.apache.camel.processor.Pipeline.process(Pipeline.java:147)
  173.     at org.apache.camel.impl.engine.CamelInternalProcessor.process(CamelInternalProcessor.java:312)
  174.     at org.apache.camel.impl.engine.DefaultAsyncProcessorAwaitManager.process(DefaultAsyncProcessorAwaitManager.java:83)
  175.     at org.apache.camel.support.AsyncProcessorSupport.process(AsyncProcessorSupport.java:41)
  176.     at org.apache.camel.component.hazelcast.listener.CamelListener.sendExchange(CamelListener.java:48)
  177.     at org.apache.camel.component.hazelcast.listener.CamelMessageListener.onMessage(CamelMessageListener.java:35)
  178.     at com.hazelcast.client.impl.proxy.ClientTopicProxy$TopicItemHandler.handleTopicEvent(ClientTopicProxy.java:97)
  179.     at com.hazelcast.client.impl.protocol.codec.TopicAddMessageListenerCodec$AbstractEventHandler.handle(TopicAddMessageListenerCodec.java:147)
  180.     at com.hazelcast.client.impl.proxy.ClientTopicProxy$TopicItemHandler.handle(ClientTopicProxy.java:85)
  181.     at com.hazelcast.client.impl.spi.impl.listener.ClientListenerServiceImpl.handleEventMessageOnCallingThread(ClientListenerServiceImpl.java:185)
  182.     at com.hazelcast.client.impl.spi.impl.listener.ClientListenerServiceImpl$ClientEventProcessor.run(ClientListenerServiceImpl.java:354)
  183.     at com.hazelcast.internal.util.executor.StripedExecutor$Worker.process(StripedExecutor.java:245)
  184.     at com.hazelcast.internal.util.executor.StripedExecutor$Worker.run(StripedExecutor.java:228)
  185. 2020-10-27 16:04:05,952 [3 - timer://foo] INFO  route1                         - Producer side: Sending data to Hazelcast topic..
  186. 2020-10-27 16:04:05,977 [lient_1.event-3] INFO  route2                         - Consumer side: Detected following action: received
  187. 2020-10-27 16:04:05,978 [lient_1.event-3] WARN  HazelcastTopicConsumer         - Error processing exchange for hazelcast consumer on object 'null' in cache 'foo'.. Exchange[]. Caused by: [java.util.concurrent.RejectedExecutionException - null]
  188. java.util.concurrent.RejectedExecutionException
  189.     at org.apache.camel.processor.errorhandler.RedeliveryErrorHandler$SimpleTask.run(RedeliveryErrorHandler.java:381)
  190.     at org.apache.camel.impl.engine.DefaultReactiveExecutor$Worker.schedule(DefaultReactiveExecutor.java:148)
  191.     at org.apache.camel.impl.engine.DefaultReactiveExecutor.scheduleMain(DefaultReactiveExecutor.java:60)
  192.     at org.apache.camel.processor.Pipeline.process(Pipeline.java:147)
  193.     at org.apache.camel.impl.engine.CamelInternalProcessor.process(CamelInternalProcessor.java:312)
  194.     at org.apache.camel.impl.engine.DefaultAsyncProcessorAwaitManager.process(DefaultAsyncProcessorAwaitManager.java:83)
  195.     at org.apache.camel.support.AsyncProcessorSupport.process(AsyncProcessorSupport.java:41)
  196.     at org.apache.camel.component.hazelcast.listener.CamelListener.sendExchange(CamelListener.java:48)
  197.     at org.apache.camel.component.hazelcast.listener.CamelMessageListener.onMessage(CamelMessageListener.java:35)
  198.     at com.hazelcast.client.impl.proxy.ClientTopicProxy$TopicItemHandler.handleTopicEvent(ClientTopicProxy.java:97)
  199.     at com.hazelcast.client.impl.protocol.codec.TopicAddMessageListenerCodec$AbstractEventHandler.handle(TopicAddMessageListenerCodec.java:147)
  200.     at com.hazelcast.client.impl.proxy.ClientTopicProxy$TopicItemHandler.handle(ClientTopicProxy.java:85)
  201.     at com.hazelcast.client.impl.spi.impl.listener.ClientListenerServiceImpl.handleEventMessageOnCallingThread(ClientListenerServiceImpl.java:185)
  202.     at com.hazelcast.client.impl.spi.impl.listener.ClientListenerServiceImpl$ClientEventProcessor.run(ClientListenerServiceImpl.java:354)
  203.     at com.hazelcast.internal.util.executor.StripedExecutor$Worker.process(StripedExecutor.java:245)
  204.     at com.hazelcast.internal.util.executor.StripedExecutor$Worker.run(StripedExecutor.java:228)
  205. 2020-10-27 16:04:10,953 [3 - timer://foo] INFO  route1                         - Producer side: Sending data to Hazelcast topic..
  206. 2020-10-27 16:04:10,964 [lient_1.event-3] INFO  route2                         - Consumer side: Detected following action: received
  207. 2020-10-27 16:04:10,964 [lient_1.event-3] WARN  HazelcastTopicConsumer         - Error processing exchange for hazelcast consumer on object 'null' in cache 'foo'.. Exchange[]. Caused by: [java.util.concurrent.RejectedExecutionException - null]
  208. java.util.concurrent.RejectedExecutionException
  209.     at org.apache.camel.processor.errorhandler.RedeliveryErrorHandler$SimpleTask.run(RedeliveryErrorHandler.java:381)
  210.     at org.apache.camel.impl.engine.DefaultReactiveExecutor$Worker.schedule(DefaultReactiveExecutor.java:148)
  211.     at org.apache.camel.impl.engine.DefaultReactiveExecutor.scheduleMain(DefaultReactiveExecutor.java:60)
  212.     at org.apache.camel.processor.Pipeline.process(Pipeline.java:147)
  213.     at org.apache.camel.impl.engine.CamelInternalProcessor.process(CamelInternalProcessor.java:312)
  214.     at org.apache.camel.impl.engine.DefaultAsyncProcessorAwaitManager.process(DefaultAsyncProcessorAwaitManager.java:83)
  215.     at org.apache.camel.support.AsyncProcessorSupport.process(AsyncProcessorSupport.java:41)
  216.     at org.apache.camel.component.hazelcast.listener.CamelListener.sendExchange(CamelListener.java:48)
  217.     at org.apache.camel.component.hazelcast.listener.CamelMessageListener.onMessage(CamelMessageListener.java:35)
  218.     at com.hazelcast.client.impl.proxy.ClientTopicProxy$TopicItemHandler.handleTopicEvent(ClientTopicProxy.java:97)
  219.     at com.hazelcast.client.impl.protocol.codec.TopicAddMessageListenerCodec$AbstractEventHandler.handle(TopicAddMessageListenerCodec.java:147)
  220.     at com.hazelcast.client.impl.proxy.ClientTopicProxy$TopicItemHandler.handle(ClientTopicProxy.java:85)
  221.     at com.hazelcast.client.impl.spi.impl.listener.ClientListenerServiceImpl.handleEventMessageOnCallingThread(ClientListenerServiceImpl.java:185)
  222.     at com.hazelcast.client.impl.spi.impl.listener.ClientListenerServiceImpl$ClientEventProcessor.run(ClientListenerServiceImpl.java:354)
  223.     at com.hazelcast.internal.util.executor.StripedExecutor$Worker.process(StripedExecutor.java:245)
  224.     at com.hazelcast.internal.util.executor.StripedExecutor$Worker.run(StripedExecutor.java:228)
  225. 2020-10-27 16:04:15,963 [3 - timer://foo] INFO  route1                         - Producer side: Sending data to Hazelcast topic..
  226. 2020-10-27 16:04:15,993 [lient_1.event-3] INFO  route2                         - Consumer side: Detected following action: received
  227. 2020-10-27 16:04:15,994 [lient_1.event-3] WARN  HazelcastTopicConsumer         - Error processing exchange for hazelcast consumer on object 'null' in cache 'foo'.. Exchange[]. Caused by: [java.util.concurrent.RejectedExecutionException - null]
  228. java.util.concurrent.RejectedExecutionException
  229.     at org.apache.camel.processor.errorhandler.RedeliveryErrorHandler$SimpleTask.run(RedeliveryErrorHandler.java:381)
  230.     at org.apache.camel.impl.engine.DefaultReactiveExecutor$Worker.schedule(DefaultReactiveExecutor.java:148)
  231.     at org.apache.camel.impl.engine.DefaultReactiveExecutor.scheduleMain(DefaultReactiveExecutor.java:60)
  232.     at org.apache.camel.processor.Pipeline.process(Pipeline.java:147)
  233.     at org.apache.camel.impl.engine.CamelInternalProcessor.process(CamelInternalProcessor.java:312)
  234.     at org.apache.camel.impl.engine.DefaultAsyncProcessorAwaitManager.process(DefaultAsyncProcessorAwaitManager.java:83)
  235.     at org.apache.camel.support.AsyncProcessorSupport.process(AsyncProcessorSupport.java:41)
  236.     at org.apache.camel.component.hazelcast.listener.CamelListener.sendExchange(CamelListener.java:48)
  237.     at org.apache.camel.component.hazelcast.listener.CamelMessageListener.onMessage(CamelMessageListener.java:35)
  238.     at com.hazelcast.client.impl.proxy.ClientTopicProxy$TopicItemHandler.handleTopicEvent(ClientTopicProxy.java:97)
  239.     at com.hazelcast.client.impl.protocol.codec.TopicAddMessageListenerCodec$AbstractEventHandler.handle(TopicAddMessageListenerCodec.java:147)
  240.     at com.hazelcast.client.impl.proxy.ClientTopicProxy$TopicItemHandler.handle(ClientTopicProxy.java:85)
  241.     at com.hazelcast.client.impl.spi.impl.listener.ClientListenerServiceImpl.handleEventMessageOnCallingThread(ClientListenerServiceImpl.java:185)
  242.     at com.hazelcast.client.impl.spi.impl.listener.ClientListenerServiceImpl$ClientEventProcessor.run(ClientListenerServiceImpl.java:354)
  243.     at com.hazelcast.internal.util.executor.StripedExecutor$Worker.process(StripedExecutor.java:245)
  244.     at com.hazelcast.internal.util.executor.StripedExecutor$Worker.run(StripedExecutor.java:228)
  245. 2020-10-27 16:04:20,969 [3 - timer://foo] INFO  route1                         - Producer side: Sending data to Hazelcast topic..
  246. 2020-10-27 16:04:20,978 [lient_1.event-3] INFO  route2                         - Consumer side: Detected following action: received
  247. 2020-10-27 16:04:20,979 [lient_1.event-3] WARN  HazelcastTopicConsumer         - Error processing exchange for hazelcast consumer on object 'null' in cache 'foo'.. Exchange[]. Caused by: [java.util.concurrent.RejectedExecutionException - null]
  248. java.util.concurrent.RejectedExecutionException
  249.     at org.apache.camel.processor.errorhandler.RedeliveryErrorHandler$SimpleTask.run(RedeliveryErrorHandler.java:381)
  250.     at org.apache.camel.impl.engine.DefaultReactiveExecutor$Worker.schedule(DefaultReactiveExecutor.java:148)
  251.     at org.apache.camel.impl.engine.DefaultReactiveExecutor.scheduleMain(DefaultReactiveExecutor.java:60)
  252.     at org.apache.camel.processor.Pipeline.process(Pipeline.java:147)
  253.     at org.apache.camel.impl.engine.CamelInternalProcessor.process(CamelInternalProcessor.java:312)
  254.     at org.apache.camel.impl.engine.DefaultAsyncProcessorAwaitManager.process(DefaultAsyncProcessorAwaitManager.java:83)
  255.     at org.apache.camel.support.AsyncProcessorSupport.process(AsyncProcessorSupport.java:41)
  256.     at org.apache.camel.component.hazelcast.listener.CamelListener.sendExchange(CamelListener.java:48)
  257.     at org.apache.camel.component.hazelcast.listener.CamelMessageListener.onMessage(CamelMessageListener.java:35)
  258.     at com.hazelcast.client.impl.proxy.ClientTopicProxy$TopicItemHandler.handleTopicEvent(ClientTopicProxy.java:97)
  259.     at com.hazelcast.client.impl.protocol.codec.TopicAddMessageListenerCodec$AbstractEventHandler.handle(TopicAddMessageListenerCodec.java:147)
  260.     at com.hazelcast.client.impl.proxy.ClientTopicProxy$TopicItemHandler.handle(ClientTopicProxy.java:85)
  261.     at com.hazelcast.client.impl.spi.impl.listener.ClientListenerServiceImpl.handleEventMessageOnCallingThread(ClientListenerServiceImpl.java:185)
  262.     at com.hazelcast.client.impl.spi.impl.listener.ClientListenerServiceImpl$ClientEventProcessor.run(ClientListenerServiceImpl.java:354)
  263.     at com.hazelcast.internal.util.executor.StripedExecutor$Worker.process(StripedExecutor.java:245)
  264.     at com.hazelcast.internal.util.executor.StripedExecutor$Worker.run(StripedExecutor.java:228)
  265. 2020-10-27 16:04:25,969 [3 - timer://foo] INFO  route1                         - Producer side: Sending data to Hazelcast topic..
  266. 2020-10-27 16:04:25,982 [lient_1.event-3] INFO  route2                         - Consumer side: Detected following action: received
  267. 2020-10-27 16:04:25,985 [lient_1.event-3] WARN  HazelcastTopicConsumer         - Error processing exchange for hazelcast consumer on object 'null' in cache 'foo'.. Exchange[]. Caused by: [java.util.concurrent.RejectedExecutionException - null]
  268. java.util.concurrent.RejectedExecutionException
  269.     at org.apache.camel.processor.errorhandler.RedeliveryErrorHandler$SimpleTask.run(RedeliveryErrorHandler.java:381)
  270.     at org.apache.camel.impl.engine.DefaultReactiveExecutor$Worker.schedule(DefaultReactiveExecutor.java:148)
  271.     at org.apache.camel.impl.engine.DefaultReactiveExecutor.scheduleMain(DefaultReactiveExecutor.java:60)
  272.     at org.apache.camel.processor.Pipeline.process(Pipeline.java:147)
  273.     at org.apache.camel.impl.engine.CamelInternalProcessor.process(CamelInternalProcessor.java:312)
  274.     at org.apache.camel.impl.engine.DefaultAsyncProcessorAwaitManager.process(DefaultAsyncProcessorAwaitManager.java:83)
  275.     at org.apache.camel.support.AsyncProcessorSupport.process(AsyncProcessorSupport.java:41)
  276.     at org.apache.camel.component.hazelcast.listener.CamelListener.sendExchange(CamelListener.java:48)
  277.     at org.apache.camel.component.hazelcast.listener.CamelMessageListener.onMessage(CamelMessageListener.java:35)
  278.     at com.hazelcast.client.impl.proxy.ClientTopicProxy$TopicItemHandler.handleTopicEvent(ClientTopicProxy.java:97)
  279.     at com.hazelcast.client.impl.protocol.codec.TopicAddMessageListenerCodec$AbstractEventHandler.handle(TopicAddMessageListenerCodec.java:147)
  280.     at com.hazelcast.client.impl.proxy.ClientTopicProxy$TopicItemHandler.handle(ClientTopicProxy.java:85)
  281.     at com.hazelcast.client.impl.spi.impl.listener.ClientListenerServiceImpl.handleEventMessageOnCallingThread(ClientListenerServiceImpl.java:185)
  282.     at com.hazelcast.client.impl.spi.impl.listener.ClientListenerServiceImpl$ClientEventProcessor.run(ClientListenerServiceImpl.java:354)
  283.     at com.hazelcast.internal.util.executor.StripedExecutor$Worker.process(StripedExecutor.java:245)
  284.     at com.hazelcast.internal.util.executor.StripedExecutor$Worker.run(StripedExecutor.java:228)
  285. 2020-10-27 16:04:30,968 [3 - timer://foo] INFO  route1                         - Producer side: Sending data to Hazelcast topic..
  286. 2020-10-27 16:04:30,971 [lient_1.event-3] INFO  route2                         - Consumer side: Detected following action: received
  287. 2020-10-27 16:04:30,971 [lient_1.event-3] WARN  HazelcastTopicConsumer         - Error processing exchange for hazelcast consumer on object 'null' in cache 'foo'.. Exchange[]. Caused by: [java.util.concurrent.RejectedExecutionException - null]
  288. java.util.concurrent.RejectedExecutionException
  289.     at org.apache.camel.processor.errorhandler.RedeliveryErrorHandler$SimpleTask.run(RedeliveryErrorHandler.java:381)
  290.     at org.apache.camel.impl.engine.DefaultReactiveExecutor$Worker.schedule(DefaultReactiveExecutor.java:148)
  291.     at org.apache.camel.impl.engine.DefaultReactiveExecutor.scheduleMain(DefaultReactiveExecutor.java:60)
  292.     at org.apache.camel.processor.Pipeline.process(Pipeline.java:147)
  293.     at org.apache.camel.impl.engine.CamelInternalProcessor.process(CamelInternalProcessor.java:312)
  294.     at org.apache.camel.impl.engine.DefaultAsyncProcessorAwaitManager.process(DefaultAsyncProcessorAwaitManager.java:83)
  295.     at org.apache.camel.support.AsyncProcessorSupport.process(AsyncProcessorSupport.java:41)
  296.     at org.apache.camel.component.hazelcast.listener.CamelListener.sendExchange(CamelListener.java:48)
  297.     at org.apache.camel.component.hazelcast.listener.CamelMessageListener.onMessage(CamelMessageListener.java:35)
  298.     at com.hazelcast.client.impl.proxy.ClientTopicProxy$TopicItemHandler.handleTopicEvent(ClientTopicProxy.java:97)
  299.     at com.hazelcast.client.impl.protocol.codec.TopicAddMessageListenerCodec$AbstractEventHandler.handle(TopicAddMessageListenerCodec.java:147)
  300.     at com.hazelcast.client.impl.proxy.ClientTopicProxy$TopicItemHandler.handle(ClientTopicProxy.java:85)
  301.     at com.hazelcast.client.impl.spi.impl.listener.ClientListenerServiceImpl.handleEventMessageOnCallingThread(ClientListenerServiceImpl.java:185)
  302.     at com.hazelcast.client.impl.spi.impl.listener.ClientListenerServiceImpl$ClientEventProcessor.run(ClientListenerServiceImpl.java:354)
  303.     at com.hazelcast.internal.util.executor.StripedExecutor$Worker.process(StripedExecutor.java:245)
  304.     at com.hazelcast.internal.util.executor.StripedExecutor$Worker.run(StripedExecutor.java:228)
  305. 2020-10-27 16:04:35,970 [3 - timer://foo] INFO  route1                         - Producer side: Sending data to Hazelcast topic..
  306. 2020-10-27 16:04:36,005 [lient_1.event-3] INFO  route2                         - Consumer side: Detected following action: received
  307. 2020-10-27 16:04:36,016 [lient_1.event-3] WARN  HazelcastTopicConsumer         - Error processing exchange for hazelcast consumer on object 'null' in cache 'foo'.. Exchange[]. Caused by: [java.util.concurrent.RejectedExecutionException - null]
  308. java.util.concurrent.RejectedExecutionException
  309.     at org.apache.camel.processor.errorhandler.RedeliveryErrorHandler$SimpleTask.run(RedeliveryErrorHandler.java:381)
  310.     at org.apache.camel.impl.engine.DefaultReactiveExecutor$Worker.schedule(DefaultReactiveExecutor.java:148)
  311.     at org.apache.camel.impl.engine.DefaultReactiveExecutor.scheduleMain(DefaultReactiveExecutor.java:60)
  312.     at org.apache.camel.processor.Pipeline.process(Pipeline.java:147)
  313.     at org.apache.camel.impl.engine.CamelInternalProcessor.process(CamelInternalProcessor.java:312)
  314.     at org.apache.camel.impl.engine.DefaultAsyncProcessorAwaitManager.process(DefaultAsyncProcessorAwaitManager.java:83)
  315.     at org.apache.camel.support.AsyncProcessorSupport.process(AsyncProcessorSupport.java:41)
  316.     at org.apache.camel.component.hazelcast.listener.CamelListener.sendExchange(CamelListener.java:48)
  317.     at org.apache.camel.component.hazelcast.listener.CamelMessageListener.onMessage(CamelMessageListener.java:35)
  318.     at com.hazelcast.client.impl.proxy.ClientTopicProxy$TopicItemHandler.handleTopicEvent(ClientTopicProxy.java:97)
  319.     at com.hazelcast.client.impl.protocol.codec.TopicAddMessageListenerCodec$AbstractEventHandler.handle(TopicAddMessageListenerCodec.java:147)
  320.     at com.hazelcast.client.impl.proxy.ClientTopicProxy$TopicItemHandler.handle(ClientTopicProxy.java:85)
  321.     at com.hazelcast.client.impl.spi.impl.listener.ClientListenerServiceImpl.handleEventMessageOnCallingThread(ClientListenerServiceImpl.java:185)
  322.     at com.hazelcast.client.impl.spi.impl.listener.ClientListenerServiceImpl$ClientEventProcessor.run(ClientListenerServiceImpl.java:354)
  323.     at com.hazelcast.internal.util.executor.StripedExecutor$Worker.process(StripedExecutor.java:245)
  324.     at com.hazelcast.internal.util.executor.StripedExecutor$Worker.run(StripedExecutor.java:228)
  325. 2020-10-27 16:04:40,969 [3 - timer://foo] INFO  route1                         - Producer side: Sending data to Hazelcast topic..
  326. 2020-10-27 16:04:40,974 [lient_1.event-3] INFO  route2                         - Consumer side: Detected following action: received
  327. 2020-10-27 16:04:40,975 [lient_1.event-3] WARN  HazelcastTopicConsumer         - Error processing exchange for hazelcast consumer on object 'null' in cache 'foo'.. Exchange[]. Caused by: [java.util.concurrent.RejectedExecutionException - null]
  328. java.util.concurrent.RejectedExecutionException
  329.     at org.apache.camel.processor.errorhandler.RedeliveryErrorHandler$SimpleTask.run(RedeliveryErrorHandler.java:381)
  330.     at org.apache.camel.impl.engine.DefaultReactiveExecutor$Worker.schedule(DefaultReactiveExecutor.java:148)
  331.     at org.apache.camel.impl.engine.DefaultReactiveExecutor.scheduleMain(DefaultReactiveExecutor.java:60)
  332.     at org.apache.camel.processor.Pipeline.process(Pipeline.java:147)
  333.     at org.apache.camel.impl.engine.CamelInternalProcessor.process(CamelInternalProcessor.java:312)
  334.     at org.apache.camel.impl.engine.DefaultAsyncProcessorAwaitManager.process(DefaultAsyncProcessorAwaitManager.java:83)
  335.     at org.apache.camel.support.AsyncProcessorSupport.process(AsyncProcessorSupport.java:41)
  336.     at org.apache.camel.component.hazelcast.listener.CamelListener.sendExchange(CamelListener.java:48)
  337.     at org.apache.camel.component.hazelcast.listener.CamelMessageListener.onMessage(CamelMessageListener.java:35)
  338.     at com.hazelcast.client.impl.proxy.ClientTopicProxy$TopicItemHandler.handleTopicEvent(ClientTopicProxy.java:97)
  339.     at com.hazelcast.client.impl.protocol.codec.TopicAddMessageListenerCodec$AbstractEventHandler.handle(TopicAddMessageListenerCodec.java:147)
  340.     at com.hazelcast.client.impl.proxy.ClientTopicProxy$TopicItemHandler.handle(ClientTopicProxy.java:85)
  341.     at com.hazelcast.client.impl.spi.impl.listener.ClientListenerServiceImpl.handleEventMessageOnCallingThread(ClientListenerServiceImpl.java:185)
  342.     at com.hazelcast.client.impl.spi.impl.listener.ClientListenerServiceImpl$ClientEventProcessor.run(ClientListenerServiceImpl.java:354)
  343.     at com.hazelcast.internal.util.executor.StripedExecutor$Worker.process(StripedExecutor.java:245)
  344.     at com.hazelcast.internal.util.executor.StripedExecutor$Worker.run(StripedExecutor.java:228)
  345. 2020-10-27 16:04:45,971 [3 - timer://foo] INFO  route1                         - Producer side: Sending data to Hazelcast topic..
  346. 2020-10-27 16:04:45,988 [lient_1.event-3] INFO  route2                         - Consumer side: Detected following action: received
  347. 2020-10-27 16:04:45,989 [lient_1.event-3] WARN  HazelcastTopicConsumer         - Error processing exchange for hazelcast consumer on object 'null' in cache 'foo'.. Exchange[]. Caused by: [java.util.concurrent.RejectedExecutionException - null]
  348. java.util.concurrent.RejectedExecutionException
  349.     at org.apache.camel.processor.errorhandler.RedeliveryErrorHandler$SimpleTask.run(RedeliveryErrorHandler.java:381)
  350.     at org.apache.camel.impl.engine.DefaultReactiveExecutor$Worker.schedule(DefaultReactiveExecutor.java:148)
  351.     at org.apache.camel.impl.engine.DefaultReactiveExecutor.scheduleMain(DefaultReactiveExecutor.java:60)
  352.     at org.apache.camel.processor.Pipeline.process(Pipeline.java:147)
  353.     at org.apache.camel.impl.engine.CamelInternalProcessor.process(CamelInternalProcessor.java:312)
  354.     at org.apache.camel.impl.engine.DefaultAsyncProcessorAwaitManager.process(DefaultAsyncProcessorAwaitManager.java:83)
  355.     at org.apache.camel.support.AsyncProcessorSupport.process(AsyncProcessorSupport.java:41)
  356.     at org.apache.camel.component.hazelcast.listener.CamelListener.sendExchange(CamelListener.java:48)
  357.     at org.apache.camel.component.hazelcast.listener.CamelMessageListener.onMessage(CamelMessageListener.java:35)
  358.     at com.hazelcast.client.impl.proxy.ClientTopicProxy$TopicItemHandler.handleTopicEvent(ClientTopicProxy.java:97)
  359.     at com.hazelcast.client.impl.protocol.codec.TopicAddMessageListenerCodec$AbstractEventHandler.handle(TopicAddMessageListenerCodec.java:147)
  360.     at com.hazelcast.client.impl.proxy.ClientTopicProxy$TopicItemHandler.handle(ClientTopicProxy.java:85)
  361.     at com.hazelcast.client.impl.spi.impl.listener.ClientListenerServiceImpl.handleEventMessageOnCallingThread(ClientListenerServiceImpl.java:185)
  362.     at com.hazelcast.client.impl.spi.impl.listener.ClientListenerServiceImpl$ClientEventProcessor.run(ClientListenerServiceImpl.java:354)
  363.     at com.hazelcast.internal.util.executor.StripedExecutor$Worker.process(StripedExecutor.java:245)
  364.     at com.hazelcast.internal.util.executor.StripedExecutor$Worker.run(StripedExecutor.java:228)
  365. 2020-10-27 16:04:50,972 [3 - timer://foo] INFO  route1                         - Producer side: Sending data to Hazelcast topic..
  366. 2020-10-27 16:04:50,978 [lient_1.event-3] INFO  route2                         - Consumer side: Detected following action: received
  367. 2020-10-27 16:04:50,980 [lient_1.event-3] WARN  HazelcastTopicConsumer         - Error processing exchange for hazelcast consumer on object 'null' in cache 'foo'.. Exchange[]. Caused by: [java.util.concurrent.RejectedExecutionException - null]
  368. java.util.concurrent.RejectedExecutionException
  369.     at org.apache.camel.processor.errorhandler.RedeliveryErrorHandler$SimpleTask.run(RedeliveryErrorHandler.java:381)
  370.     at org.apache.camel.impl.engine.DefaultReactiveExecutor$Worker.schedule(DefaultReactiveExecutor.java:148)
  371.     at org.apache.camel.impl.engine.DefaultReactiveExecutor.scheduleMain(DefaultReactiveExecutor.java:60)
  372.     at org.apache.camel.processor.Pipeline.process(Pipeline.java:147)
  373.     at org.apache.camel.impl.engine.CamelInternalProcessor.process(CamelInternalProcessor.java:312)
  374.     at org.apache.camel.impl.engine.DefaultAsyncProcessorAwaitManager.process(DefaultAsyncProcessorAwaitManager.java:83)
  375.     at org.apache.camel.support.AsyncProcessorSupport.process(AsyncProcessorSupport.java:41)
  376.     at org.apache.camel.component.hazelcast.listener.CamelListener.sendExchange(CamelListener.java:48)
  377.     at org.apache.camel.component.hazelcast.listener.CamelMessageListener.onMessage(CamelMessageListener.java:35)
  378.     at com.hazelcast.client.impl.proxy.ClientTopicProxy$TopicItemHandler.handleTopicEvent(ClientTopicProxy.java:97)
  379.     at com.hazelcast.client.impl.protocol.codec.TopicAddMessageListenerCodec$AbstractEventHandler.handle(TopicAddMessageListenerCodec.java:147)
  380.     at com.hazelcast.client.impl.proxy.ClientTopicProxy$TopicItemHandler.handle(ClientTopicProxy.java:85)
  381.     at com.hazelcast.client.impl.spi.impl.listener.ClientListenerServiceImpl.handleEventMessageOnCallingThread(ClientListenerServiceImpl.java:185)
  382.     at com.hazelcast.client.impl.spi.impl.listener.ClientListenerServiceImpl$ClientEventProcessor.run(ClientListenerServiceImpl.java:354)
  383.     at com.hazelcast.internal.util.executor.StripedExecutor$Worker.process(StripedExecutor.java:245)
  384.     at com.hazelcast.internal.util.executor.StripedExecutor$Worker.run(StripedExecutor.java:228)
  385. 2020-10-27 16:04:55,972 [3 - timer://foo] INFO  route1                         - Producer side: Sending data to Hazelcast topic..
  386. 2020-10-27 16:04:55,977 [lient_1.event-3] INFO  route2                         - Consumer side: Detected following action: received
  387. 2020-10-27 16:04:55,977 [lient_1.event-3] WARN  HazelcastTopicConsumer         - Error processing exchange for hazelcast consumer on object 'null' in cache 'foo'.. Exchange[]. Caused by: [java.util.concurrent.RejectedExecutionException - null]
  388. java.util.concurrent.RejectedExecutionException
  389.     at org.apache.camel.processor.errorhandler.RedeliveryErrorHandler$SimpleTask.run(RedeliveryErrorHandler.java:381)
  390.     at org.apache.camel.impl.engine.DefaultReactiveExecutor$Worker.schedule(DefaultReactiveExecutor.java:148)
  391.     at org.apache.camel.impl.engine.DefaultReactiveExecutor.scheduleMain(DefaultReactiveExecutor.java:60)
  392.     at org.apache.camel.processor.Pipeline.process(Pipeline.java:147)
  393.     at org.apache.camel.impl.engine.CamelInternalProcessor.process(CamelInternalProcessor.java:312)
  394.     at org.apache.camel.impl.engine.DefaultAsyncProcessorAwaitManager.process(DefaultAsyncProcessorAwaitManager.java:83)
  395.     at org.apache.camel.support.AsyncProcessorSupport.process(AsyncProcessorSupport.java:41)
  396.     at org.apache.camel.component.hazelcast.listener.CamelListener.sendExchange(CamelListener.java:48)
  397.     at org.apache.camel.component.hazelcast.listener.CamelMessageListener.onMessage(CamelMessageListener.java:35)
  398.     at com.hazelcast.client.impl.proxy.ClientTopicProxy$TopicItemHandler.handleTopicEvent(ClientTopicProxy.java:97)
  399.     at com.hazelcast.client.impl.protocol.codec.TopicAddMessageListenerCodec$AbstractEventHandler.handle(TopicAddMessageListenerCodec.java:147)
  400.     at com.hazelcast.client.impl.proxy.ClientTopicProxy$TopicItemHandler.handle(ClientTopicProxy.java:85)
  401.     at com.hazelcast.client.impl.spi.impl.listener.ClientListenerServiceImpl.handleEventMessageOnCallingThread(ClientListenerServiceImpl.java:185)
  402.     at com.hazelcast.client.impl.spi.impl.listener.ClientListenerServiceImpl$ClientEventProcessor.run(ClientListenerServiceImpl.java:354)
  403.     at com.hazelcast.internal.util.executor.StripedExecutor$Worker.process(StripedExecutor.java:245)
  404.     at com.hazelcast.internal.util.executor.StripedExecutor$Worker.run(StripedExecutor.java:228)
  405. 2020-10-27 16:05:00,972 [3 - timer://foo] INFO  route1                         - Producer side: Sending data to Hazelcast topic..
  406. 2020-10-27 16:05:00,995 [lient_1.event-3] INFO  route2                         - Consumer side: Detected following action: received
  407. 2020-10-27 16:05:01,010 [lient_1.event-3] WARN  HazelcastTopicConsumer         - Error processing exchange for hazelcast consumer on object 'null' in cache 'foo'.. Exchange[]. Caused by: [java.util.concurrent.RejectedExecutionException - null]
  408. java.util.concurrent.RejectedExecutionException
  409.     at org.apache.camel.processor.errorhandler.RedeliveryErrorHandler$SimpleTask.run(RedeliveryErrorHandler.java:381)
  410.     at org.apache.camel.impl.engine.DefaultReactiveExecutor$Worker.schedule(DefaultReactiveExecutor.java:148)
  411.     at org.apache.camel.impl.engine.DefaultReactiveExecutor.scheduleMain(DefaultReactiveExecutor.java:60)
  412.     at org.apache.camel.processor.Pipeline.process(Pipeline.java:147)
  413.     at org.apache.camel.impl.engine.CamelInternalProcessor.process(CamelInternalProcessor.java:312)
  414.     at org.apache.camel.impl.engine.DefaultAsyncProcessorAwaitManager.process(DefaultAsyncProcessorAwaitManager.java:83)
  415.     at org.apache.camel.support.AsyncProcessorSupport.process(AsyncProcessorSupport.java:41)
  416.     at org.apache.camel.component.hazelcast.listener.CamelListener.sendExchange(CamelListener.java:48)
  417.     at org.apache.camel.component.hazelcast.listener.CamelMessageListener.onMessage(CamelMessageListener.java:35)
  418.     at com.hazelcast.client.impl.proxy.ClientTopicProxy$TopicItemHandler.handleTopicEvent(ClientTopicProxy.java:97)
  419.     at com.hazelcast.client.impl.protocol.codec.TopicAddMessageListenerCodec$AbstractEventHandler.handle(TopicAddMessageListenerCodec.java:147)
  420.     at com.hazelcast.client.impl.proxy.ClientTopicProxy$TopicItemHandler.handle(ClientTopicProxy.java:85)
  421.     at com.hazelcast.client.impl.spi.impl.listener.ClientListenerServiceImpl.handleEventMessageOnCallingThread(ClientListenerServiceImpl.java:185)
  422.     at com.hazelcast.client.impl.spi.impl.listener.ClientListenerServiceImpl$ClientEventProcessor.run(ClientListenerServiceImpl.java:354)
  423.     at com.hazelcast.internal.util.executor.StripedExecutor$Worker.process(StripedExecutor.java:245)
  424.     at com.hazelcast.internal.util.executor.StripedExecutor$Worker.run(StripedExecutor.java:228)
  425. 2020-10-27 16:05:05,978 [3 - timer://foo] INFO  route1                         - Producer side: Sending data to Hazelcast topic..
  426. 2020-10-27 16:05:05,992 [lient_1.event-3] INFO  route2                         - Consumer side: Detected following action: received
  427. 2020-10-27 16:05:05,993 [lient_1.event-3] WARN  HazelcastTopicConsumer         - Error processing exchange for hazelcast consumer on object 'null' in cache 'foo'.. Exchange[]. Caused by: [java.util.concurrent.RejectedExecutionException - null]
  428. java.util.concurrent.RejectedExecutionException
  429.     at org.apache.camel.processor.errorhandler.RedeliveryErrorHandler$SimpleTask.run(RedeliveryErrorHandler.java:381)
  430.     at org.apache.camel.impl.engine.DefaultReactiveExecutor$Worker.schedule(DefaultReactiveExecutor.java:148)
  431.     at org.apache.camel.impl.engine.DefaultReactiveExecutor.scheduleMain(DefaultReactiveExecutor.java:60)
  432.     at org.apache.camel.processor.Pipeline.process(Pipeline.java:147)
  433.     at org.apache.camel.impl.engine.CamelInternalProcessor.process(CamelInternalProcessor.java:312)
  434.     at org.apache.camel.impl.engine.DefaultAsyncProcessorAwaitManager.process(DefaultAsyncProcessorAwaitManager.java:83)
  435.     at org.apache.camel.support.AsyncProcessorSupport.process(AsyncProcessorSupport.java:41)
  436.     at org.apache.camel.component.hazelcast.listener.CamelListener.sendExchange(CamelListener.java:48)
  437.     at org.apache.camel.component.hazelcast.listener.CamelMessageListener.onMessage(CamelMessageListener.java:35)
  438.     at com.hazelcast.client.impl.proxy.ClientTopicProxy$TopicItemHandler.handleTopicEvent(ClientTopicProxy.java:97)
  439.     at com.hazelcast.client.impl.protocol.codec.TopicAddMessageListenerCodec$AbstractEventHandler.handle(TopicAddMessageListenerCodec.java:147)
  440.     at com.hazelcast.client.impl.proxy.ClientTopicProxy$TopicItemHandler.handle(ClientTopicProxy.java:85)
  441.     at com.hazelcast.client.impl.spi.impl.listener.ClientListenerServiceImpl.handleEventMessageOnCallingThread(ClientListenerServiceImpl.java:185)
  442.     at com.hazelcast.client.impl.spi.impl.listener.ClientListenerServiceImpl$ClientEventProcessor.run(ClientListenerServiceImpl.java:354)
  443.     at com.hazelcast.internal.util.executor.StripedExecutor$Worker.process(StripedExecutor.java:245)
  444.     at com.hazelcast.internal.util.executor.StripedExecutor$Worker.run(StripedExecutor.java:228)
  445. 2020-10-27 16:05:10,975 [3 - timer://foo] INFO  route1                         - Producer side: Sending data to Hazelcast topic..
  446. 2020-10-27 16:05:11,016 [lient_1.event-3] INFO  route2                         - Consumer side: Detected following action: received
  447. 2020-10-27 16:05:11,018 [lient_1.event-3] WARN  HazelcastTopicConsumer         - Error processing exchange for hazelcast consumer on object 'null' in cache 'foo'.. Exchange[]. Caused by: [java.util.concurrent.RejectedExecutionException - null]
  448. java.util.concurrent.RejectedExecutionException
  449.     at org.apache.camel.processor.errorhandler.RedeliveryErrorHandler$SimpleTask.run(RedeliveryErrorHandler.java:381)
  450.     at org.apache.camel.impl.engine.DefaultReactiveExecutor$Worker.schedule(DefaultReactiveExecutor.java:148)
  451.     at org.apache.camel.impl.engine.DefaultReactiveExecutor.scheduleMain(DefaultReactiveExecutor.java:60)
  452.     at org.apache.camel.processor.Pipeline.process(Pipeline.java:147)
  453.     at org.apache.camel.impl.engine.CamelInternalProcessor.process(CamelInternalProcessor.java:312)
  454.     at org.apache.camel.impl.engine.DefaultAsyncProcessorAwaitManager.process(DefaultAsyncProcessorAwaitManager.java:83)
  455.     at org.apache.camel.support.AsyncProcessorSupport.process(AsyncProcessorSupport.java:41)
  456.     at org.apache.camel.component.hazelcast.listener.CamelListener.sendExchange(CamelListener.java:48)
  457.     at org.apache.camel.component.hazelcast.listener.CamelMessageListener.onMessage(CamelMessageListener.java:35)
  458.     at com.hazelcast.client.impl.proxy.ClientTopicProxy$TopicItemHandler.handleTopicEvent(ClientTopicProxy.java:97)
  459.     at com.hazelcast.client.impl.protocol.codec.TopicAddMessageListenerCodec$AbstractEventHandler.handle(TopicAddMessageListenerCodec.java:147)
  460.     at com.hazelcast.client.impl.proxy.ClientTopicProxy$TopicItemHandler.handle(ClientTopicProxy.java:85)
  461.     at com.hazelcast.client.impl.spi.impl.listener.ClientListenerServiceImpl.handleEventMessageOnCallingThread(ClientListenerServiceImpl.java:185)
  462.     at com.hazelcast.client.impl.spi.impl.listener.ClientListenerServiceImpl$ClientEventProcessor.run(ClientListenerServiceImpl.java:354)
  463.     at com.hazelcast.internal.util.executor.StripedExecutor$Worker.process(StripedExecutor.java:245)
  464.     at com.hazelcast.internal.util.executor.StripedExecutor$Worker.run(StripedExecutor.java:228)
  465.  
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement
Public Pastes
Advertisement
We use cookies for various purposes including analytics. By continuing to use Pastebin, you agree to our use of cookies as described in the Cookies Policy.  OK, I Understand
Not a member of Pastebin yet?
Sign Up, it unlocks many cool features!