[jira] [Resolved] (CAMEL-15899) HazelcastConsumers do not remove their listeners

["Andrea Cosentino (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/CAMEL-15899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Andrea Cosentino resolved CAMEL-15899.
--------------------------------------
    Resolution: Fixed

> HazelcastConsumers do not remove their listeners
> ------------------------------------------------
>
>                 Key: CAMEL-15899
>                 URL: https://issues.apache.org/jira/browse/CAMEL-15899
>             Project: Camel
>          Issue Type: Bug
>          Components: camel-hazelcast
>    Affects Versions: 3.5.0, 3.4.4, 3.6.0
>            Reporter: Florian Agsteiner
>            Assignee: Andrea Cosentino
>            Priority: Major
>             Fix For: 3.7.0
>
>
> The following exception occurs if the camelroute with a hazel cast topic is restarted  
> {code:java}
> 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)
> {code}
> Solution
> Register listeners in doStart and remove them in doStop



--
This message was sent by Atlassian Jira
(v8.3.4#803005)