[CAMEL-15899] HazelcastConsumers do not remove their listeners

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 3.5.0, 3.4.4, 3.6.0
• Fix Version/s: 3.7.0
• Component/s: camel-hazelcast
• Estimated Complexity: Unknown
• Assignee: Andrea Cosentino
• Reporter: Florian Agsteiner
• Created: 27/Nov/20 10:20
• Updated: 03/Dec/20 13:24
• Resolved: 03/Dec/20 13:24

Description

The following exception occurs if the camelroute with a hazel cast topic is restarted

WARNUNG: Error processing exchange for hazelcast consumer on object 'null' in cache 'server.trace.event'.. Exchange[ID-1605875260724-0-338]. Caused by: [java.util.concurrent.RejectedExecutionException - null]
java.util.concurrent.RejectedExecutionException
at org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:435)
at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:201)
at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:201)
at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:97)
at org.apache.camel.component.hazelcast.listener.CamelListener.sendExchange(CamelListener.java:48)
at org.apache.camel.component.hazelcast.listener.CamelMessageListener.onMessage(CamelMessageListener.java:34)
at com.hazelcast.topic.impl.TopicService.dispatchEvent(TopicService.java:138)
at com.hazelcast.spi.impl.eventservice.impl.LocalEventDispatcher.run(LocalEventDispatcher.java:64)
at com.hazelcast.util.executor.StripedExecutor$Worker.process(StripedExecutor.java:244)
at com.hazelcast.util.executor.StripedExecutor$Worker.run(StripedExecutor.java:227)

Solution
Register listeners in doStart and remove them in doStop

Issue Links

• links to: GitHub Pull Request #4694
• links to: GitHub Pull Request #4696