You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@activemq.apache.org by Jose María Zaragoza <de...@gmail.com> on 2013/10/10 17:13:19 UTC
javax.jms.IllegalStateException: The Consumer is closed
Hello:
I'm using AMQ 5.8 ( + integration with Spring ) and I'm getting this
error sometimes in my application's logfile
I attatch the log stacktrace
What could be the reason ? Was a problem on client or on server ? a
server failover ?
Thanks
[ActiveMQ Transport: tcp://broker1/127.0.0.1:61616@41534] 12:37:27,433
WARN org.apache.activemq.transport.failover.FailoverTransport.handleTransportFailure(FailoverTransport.java:255)
- Transport (tcp://127.0.0.1:61616) failed, reason:
java.io.EOFException, not attempting to automatically reconnect
[org.springframework.jms.listener.DefaultMessageListenerContainer#dc7df0d-2]
12:37:27,443 WARN
org.springframework.jms.listener.DefaultMessageListenerContainer.handleListenerSetupFailure(DefaultMessageListenerContainer.java:818)
- Setup of JMS message listener invoker failed for destination
'OLSMS.TO.C2C' - trying to recover. Cause: The Consumer is closed
javax.jms.IllegalStateException: The Consumer is closed
at org.apache.activemq.ActiveMQMessageConsumer.checkClosed(ActiveMQMessageConsumer.java:817)
at org.apache.activemq.ActiveMQMessageConsumer.receive(ActiveMQMessageConsumer.java:581)
at org.apache.activemq.pool.PooledMessageConsumer.receive(PooledMessageConsumer.java:67)
at org.springframework.jms.listener.AbstractPollingMessageListenerContainer.receiveMessage(AbstractPollingMessageListenerContainer.java:429)
at org.springframework.jms.listener.AbstractPollingMessageListenerContainer.doReceiveAndExecute(AbstractPollingMessageListenerContainer.java:310)
at org.springframework.jms.listener.AbstractPollingMessageListenerContainer.receiveAndExecute(AbstractPollingMessageListenerContainer.java:263)
at org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.invokeListener(DefaultMessageListenerContainer.java:1058)
at org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.executeOngoingLoop(DefaultMessageListenerContainer.java:1050)
at org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.run(DefaultMessageListenerContainer.java:947)
Re: javax.jms.IllegalStateException: The Consumer is closed
Posted by Rajesh Malla <ma...@gmail.com>.
Hello,
we are facing similar problem Consumer is closed. and we are setting below
parameters on DMLC
listenerContainer.setIdleConsumerLimit(idleConsumerLimit);
listenerContainer.setReceiveTimeout(defaultReceiveTimeout);
listenerContainer.setRecoveryInterval(defaultRecoveryInterval);
so the cache level is default [ CACHE_NONE ].
we have scenario like below
A[amq broker] # B[amq broker] ------> C [amq broker client] but we are
getting this consumer is closed error.
we are getting some other errors, some how our client is not able to
reconnect after 12 hours, after that when we restart again it is working
properly for some hours.
Any suggestions ?
--
Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html
Re: javax.jms.IllegalStateException: The Consumer is closed
Posted by Christian Posta <ch...@gmail.com>.
What cacheLevel are you using for your spring DMLC?
On Thu, Oct 10, 2013 at 8:13 AM, Jose María Zaragoza
<de...@gmail.com>wrote:
> Hello:
>
> I'm using AMQ 5.8 ( + integration with Spring ) and I'm getting this
> error sometimes in my application's logfile
> I attatch the log stacktrace
>
> What could be the reason ? Was a problem on client or on server ? a
> server failover ?
>
> Thanks
>
>
> [ActiveMQ Transport: tcp://broker1/127.0.0.1:61616@41534] 12:37:27,433
> WARN
> org.apache.activemq.transport.failover.FailoverTransport.handleTransportFailure(FailoverTransport.java:255)
> - Transport (tcp://127.0.0.1:61616) failed, reason:
> java.io.EOFException, not attempting to automatically reconnect
>
> [org.springframework.jms.listener.DefaultMessageListenerContainer#dc7df0d-2]
> 12:37:27,443 WARN
>
> org.springframework.jms.listener.DefaultMessageListenerContainer.handleListenerSetupFailure(DefaultMessageListenerContainer.java:818)
> - Setup of JMS message listener invoker failed for destination
> 'OLSMS.TO.C2C' - trying to recover. Cause: The Consumer is closed
> javax.jms.IllegalStateException: The Consumer is closed
> at
> org.apache.activemq.ActiveMQMessageConsumer.checkClosed(ActiveMQMessageConsumer.java:817)
> at
> org.apache.activemq.ActiveMQMessageConsumer.receive(ActiveMQMessageConsumer.java:581)
> at
> org.apache.activemq.pool.PooledMessageConsumer.receive(PooledMessageConsumer.java:67)
> at
> org.springframework.jms.listener.AbstractPollingMessageListenerContainer.receiveMessage(AbstractPollingMessageListenerContainer.java:429)
> at
> org.springframework.jms.listener.AbstractPollingMessageListenerContainer.doReceiveAndExecute(AbstractPollingMessageListenerContainer.java:310)
> at
> org.springframework.jms.listener.AbstractPollingMessageListenerContainer.receiveAndExecute(AbstractPollingMessageListenerContainer.java:263)
> at
> org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.invokeListener(DefaultMessageListenerContainer.java:1058)
> at
> org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.executeOngoingLoop(DefaultMessageListenerContainer.java:1050)
> at
> org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.run(DefaultMessageListenerContainer.java:947)
>
--
*Christian Posta*
http://www.christianposta.com/blog
twitter: @christianposta
Re: javax.jms.IllegalStateException: The Consumer is closed
Posted by Timothy Bish <ta...@gmail.com>.
On 10/10/2013 11:13 AM, Jose María Zaragoza wrote:
> Hello:
>
> I'm using AMQ 5.8 ( + integration with Spring ) and I'm getting this
> error sometimes in my application's logfile
> I attatch the log stacktrace
>
> What could be the reason ? Was a problem on client or on server ? a
> server failover ?
>
> Thanks
>
>
> [ActiveMQ Transport: tcp://broker1/127.0.0.1:61616@41534] 12:37:27,433
> WARN org.apache.activemq.transport.failover.FailoverTransport.handleTransportFailure(FailoverTransport.java:255)
> - Transport (tcp://127.0.0.1:61616) failed, reason:
> java.io.EOFException, not attempting to automatically reconnect
> [org.springframework.jms.listener.DefaultMessageListenerContainer#dc7df0d-2]
> 12:37:27,443 WARN
> org.springframework.jms.listener.DefaultMessageListenerContainer.handleListenerSetupFailure(DefaultMessageListenerContainer.java:818)
> - Setup of JMS message listener invoker failed for destination
> 'OLSMS.TO.C2C' - trying to recover. Cause: The Consumer is closed
> javax.jms.IllegalStateException: The Consumer is closed
> at org.apache.activemq.ActiveMQMessageConsumer.checkClosed(ActiveMQMessageConsumer.java:817)
> at org.apache.activemq.ActiveMQMessageConsumer.receive(ActiveMQMessageConsumer.java:581)
> at org.apache.activemq.pool.PooledMessageConsumer.receive(PooledMessageConsumer.java:67)
> at org.springframework.jms.listener.AbstractPollingMessageListenerContainer.receiveMessage(AbstractPollingMessageListenerContainer.java:429)
> at org.springframework.jms.listener.AbstractPollingMessageListenerContainer.doReceiveAndExecute(AbstractPollingMessageListenerContainer.java:310)
> at org.springframework.jms.listener.AbstractPollingMessageListenerContainer.receiveAndExecute(AbstractPollingMessageListenerContainer.java:263)
> at org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.invokeListener(DefaultMessageListenerContainer.java:1058)
> at org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.executeOngoingLoop(DefaultMessageListenerContainer.java:1050)
> at org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.run(DefaultMessageListenerContainer.java:947)
>
It's possible you are running into this bug:
https://issues.apache.org/jira/browse/AMQ-4366
--
Tim Bish
Sr Software Engineer | RedHat Inc.
tim.bish@redhat.com | www.fusesource.com | www.redhat.com
skype: tabish121 | twitter: @tabish121
blog: http://timbish.blogspot.com/