Activemq consumer is closing

classic Classic list List threaded Threaded
22 messages Options
12
Reply | Threaded
Open this post in threaded view
|

Activemq consumer is closing

kiranreddykasa
Hi

Consumer closes with the exception below ,could someone explain me what's causing this error?



WARN Camel (camelcontext) thread #35 - TemporaryQueueReplyManager[connect.test] org.apache.camel.component.jms.reply.TemporaryQueueReplyManager - Exception inside the DMLC for Temporary ReplyTo Queue for destination connect.test, refreshing ReplyTo destination
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:431)
        at org.springframework.jms.listener.AbstractPollingMessageListenerContainer.doReceiveAndExecute(AbstractPollingMessageListenerContainer.java:311)
        at org.springframework.jms.listener.AbstractPollingMessageListenerContainer.receiveAndExecute(AbstractPollingMessageListenerContainer.java:264)
        at org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.invokeListener(DefaultMessageListenerContainer.java:1069)
        at org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.executeOngoingLoop(DefaultMessageListenerContainer.java:1061)
        at org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.run(DefaultMessageListenerContainer.java:958)
        at java.lang.Thread.run(Thread.java:619)
Regards

kiran Reddy
Reply | Threaded
Open this post in threaded view
|

Re: Activemq consumer is closing

kiranreddykasa
Never mind, autoStart was set to false.
Regards

kiran Reddy
Reply | Threaded
Open this post in threaded view
|

Re: Activemq consumer is closing

indrayani
Hello,
can you explain what is the actual solution you applied in order to avoid this exception.
I am facing the same issue and I really need a help.

Reply | Threaded
Open this post in threaded view
|

Re: Activemq consumer is closing

Christian Mueller
Administrator
There is not enough input that we can start digging into it...

http://camel.apache.org/support.html

Best,
Christian

Sent from a mobile device
Am 18.06.2013 14:01 schrieb "indrayani" <[hidden email]>:

> Hello,
> can you explain what is the actual solution you applied in order to avoid
> this exception.
> I am facing the same issue and I really need a help.
>
>
>
>
>
> --
> View this message in context:
> http://camel.465427.n5.nabble.com/Activemq-consumer-is-closing-tp5731140p5734294.html
> Sent from the Camel - Users mailing list archive at Nabble.com.
>
Reply | Threaded
Open this post in threaded view
|

Re: Activemq consumer is closing

indrayani
I am facing the same " consumer closed issue " that ' kiranreddykasa ' was facing and from her post what i found was she has got the solution of autostart, so just wanted to know how did she apply that solution.
in which xml she did changes.
Reply | Threaded
Open this post in threaded view
|

Re: Activemq consumer is closing

kiranreddykasa
Hi

We have created activemq consumer with property autostartup = false. So the queue wasn't created and it while it was trying to write to the queue (which doesn't exist) we got that exception.

Once we changed that autostartup = true , it was fine.
Regards

kiran Reddy
Reply | Threaded
Open this post in threaded view
|

Re: Activemq consumer is closing

indrayani
This post has NOT been accepted by the mailing list yet.
hi,
thanks for the quick reply.

actually my scenario is little different , I am not creating any consumer on camel side. I have just defined routes .
if you have some time, then can you please check the following scenario.
what is happening is, first and second time communication works fine, but for the third time I am getting
consumer closed and session closed exceptions.
It would be really helpful if you check the following scenario and help me out .
------------------------------------------------

the communication is happening between two applications deployed on tomcat via camel applicaiton which is also deployed on tomcat.


camel routes are as follows :

  public void configure() {
      from("servlet:///servletA")
            .process(new Processor() {
                               
                                @Override
                                public void process(Exchange exchange) throws Exception {
                                        System.out.println("*** from servletA to activemq inbox");
                                       
                                }
                        })
                        .to("activemq:queue:inbox");
     
      from("activemq:queue:inbox")
        .setHeader(Exchange.HTTP_METHOD, constant("POST"))
        .process(new Processor() {
                       
                        @Override
                        public void process(Exchange exchange) throws Exception {
                                System.out.println("*** from activemq inbox to applicationB");
                               
                        }
                })
                .to ("http://localhost:8082/applicationB/a.do?bridgeEndpoint=true")
                .process(new Processor() {
                       
                        @Override
                        public void process(Exchange exchange) throws Exception {
                                System.out.println("*** from applicationB  back to the caller that is servletA");
                                exchange.getOut().setHeader("JOB_NO", exchange.getIn().getHeader("JOB_NO"));
                        }
                });
     
   
      from("servlet:///servletC")
      .process(new Processor() {
                       
                        @Override
                        public void process(Exchange exchange) throws Exception {
                                System.out.println("*** from servletC to activemq inboxD");
                               
                        }
                })
                .to("activemq:queue:inboxD");
               
      from("activemq:queue:inboxD")
      .setHeader(Exchange.HTTP_METHOD, constant("POST"))
      .process(new Processor() {
                       
                        @Override
                        public void process(Exchange exchange) throws Exception {
                                System.out.println("*** from activemq inboxD to applicationE");
                        }
                })
                .to(ExchangePattern.InOnly,"http://localhost:8082/applicationE/agentResp?bridgeEndpoint=true");
   
    }

Please let me know if you need any more details.
Reply | Threaded
Open this post in threaded view
|

Re: Activemq consumer is closing

kiranreddykasa
can U try setting  "replyToType"=Exclusive and "replyTo"=anyqueue

 
Regards

kiran Reddy
Reply | Threaded
Open this post in threaded view
|

Re: Activemq consumer is closing

Christian Mueller
Administrator
In reply to this post by indrayani
The consumer for which which queue was closed? Can you share the complete
stack trace?

Best,

Christian Müller
-----------------

Software Integration Specialist

Apache Camel committer: https://camel.apache.org/team
V.P. Apache Camel: https://www.apache.org/foundation/
Apache Member: https://www.apache.org/foundation/members.html

https://www.linkedin.com/pub/christian-mueller/11/551/642


On Wed, Jun 19, 2013 at 9:18 AM, indrayani <[hidden email]> wrote:

> hi,
> thanks for the quick reply.
>
> actually my scenario is little different , I am not creating any consumer
> on
> camel side. I have just defined routes .
> if you have some time, then can you please check the following scenario.
> what is happening is, first and second time communication works fine, but
> for the third time I am getting
> consumer closed and session closed exceptions.
> It would be really helpful if you check the following scenario and help me
> out .
> ------------------------------------------------
>
> the communication is happening between two applications deployed on tomcat
> via camel applicaiton which is also deployed on tomcat.
>
>
> camel routes are as follows :
>
>   public void configure() {
>       from("servlet:///servletA")
>             .process(new Processor() {
>
>                                 @Override
>                                 public void process(Exchange exchange)
> throws Exception {
>                                         System.out.println("*** from
> servletA to activemq inbox");
>
>                                 }
>                         })
>                         .to("activemq:queue:inbox");
>
>       from("activemq:queue:inbox")
>         .setHeader(Exchange.HTTP_METHOD, constant("POST"))
>         .process(new Processor() {
>
>                         @Override
>                         public void process(Exchange exchange) throws
> Exception {
>                                 System.out.println("*** from activemq inbox
> to applicationB");
>
>                         }
>                 })
>                 .to
> ("http://localhost:8082/applicationB/a.do?bridgeEndpoint=true")
>                 .process(new Processor() {
>
>                         @Override
>                         public void process(Exchange exchange) throws
> Exception {
>                                 System.out.println("*** from applicationB
> back to the caller that is servletA");
>                                 exchange.getOut().setHeader("JOB_NO",
> exchange.getIn().getHeader("JOB_NO"));
>                         }
>                 });
>
>
>       from("servlet:///servletC")
>       .process(new Processor() {
>
>                         @Override
>                         public void process(Exchange exchange) throws
> Exception {
>                                 System.out.println("*** from servletC to
> activemq inboxD");
>
>                         }
>                 })
>                 .to("activemq:queue:inboxD");
>
>       from("activemq:queue:inboxD")
>       .setHeader(Exchange.HTTP_METHOD, constant("POST"))
>       .process(new Processor() {
>
>                         @Override
>                         public void process(Exchange exchange) throws
> Exception {
>                                 System.out.println("*** from activemq
> inboxD
> to applicationE");
>                         }
>                 })
>
> .to(ExchangePattern.InOnly,"
> http://localhost:8082/applicationE/agentResp?bridgeEndpoint=true");
>
>     }
>
> Please let me know if you need any more details.
>
>
>
> --
> View this message in context:
> http://camel.465427.n5.nabble.com/Activemq-consumer-is-closing-tp5731140p5734337.html
> Sent from the Camel - Users mailing list archive at Nabble.com.
>
Reply | Threaded
Open this post in threaded view
|

Re: Activemq consumer is closing

Claus Ibsen-2
In reply to this post by kiranreddykasa
Hi

Its just a warning being logged.
Does something stop working?


You can change the logging verbosity with the options:
errorHandlerLogStackTrace
errorHandlerLoggingLevel

See
http://camel.apache.org/jms

And what version of ActiveMQ and Camel do you use?


On Fri, Apr 19, 2013 at 12:51 PM, kiranreddykasa <[hidden email]> wrote:

> Hi
>
> Consumer closes with the exception below ,could someone explain me what's
> causing this error?
>
>
>
> WARN Camel (camelcontext) thread #35 -
> TemporaryQueueReplyManager[connect.test]
> org.apache.camel.component.jms.reply.TemporaryQueueReplyManager - Exception
> inside the DMLC for Temporary ReplyTo Queue for destination connect.test,
> refreshing ReplyTo destination
> 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:431)
>         at
> org.springframework.jms.listener.AbstractPollingMessageListenerContainer.doReceiveAndExecute(AbstractPollingMessageListenerContainer.java:311)
>         at
> org.springframework.jms.listener.AbstractPollingMessageListenerContainer.receiveAndExecute(AbstractPollingMessageListenerContainer.java:264)
>         at
> org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.invokeListener(DefaultMessageListenerContainer.java:1069)
>         at
> org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.executeOngoingLoop(DefaultMessageListenerContainer.java:1061)
>         at
> org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.run(DefaultMessageListenerContainer.java:958)
>         at java.lang.Thread.run(Thread.java:619)
>
>
>
> -----
> Regards
>
> kiran Reddy
> --
> View this message in context: http://camel.465427.n5.nabble.com/Activemq-consumer-is-closing-tp5731140.html
> Sent from the Camel - Users mailing list archive at Nabble.com.



--
Claus Ibsen
-----------------
www.camelone.org: The open source integration conference.

Red Hat, Inc.
FuseSource is now part of Red Hat
Email: [hidden email]
Web: http://fusesource.com
Twitter: davsclaus
Blog: http://davsclaus.com
Author of Camel in Action: http://www.manning.com/ibsen
Reply | Threaded
Open this post in threaded view
|

Re: Activemq consumer is closing

kiranreddykasa
Hi

I got this warning while using  temporary reply queues. But once I moved to exclusive reply queues it's fine.

camel version : 2.10.3
activemq : 5.7.0
Regards

kiran Reddy
Reply | Threaded
Open this post in threaded view
|

Re: Activemq consumer is closing

kiranreddykasa
And  it was not working because of autoStartup=false.

As you said it's just a warning.

Regards

kiran Reddy
Reply | Threaded
Open this post in threaded view
|

Re: Activemq consumer is closing

indrayani
In reply to this post by kiranreddykasa
i tried but still i am getting the exceptions
Reply | Threaded
Open this post in threaded view
|

Re: Activemq consumer is closing

indrayani
In reply to this post by Claus Ibsen-2
Hi ,
I understood that these are just warnings ,
but what could be the reason behind getting consumer closed and session closed warnings.
if you check the scenario that i have mentioned , then in that case , 2 web applications are communicating with each other via camel routes which consist of servlet and actimq endpoints,
now in this case , neither of the web application is down, but still after first 2 request-reply , i am getting consumer closed exception for one of the activemq and session closed exception for the other activemq.

I am just curious, why am i not getting the exceptions in the first 2 communictions and why for 3rd ?

it would be really helpful if you elaborate more on this.
Reply | Threaded
Open this post in threaded view
|

Re: Activemq consumer is closing

indrayani
In reply to this post by Christian Mueller
below is the full stack trace


2013-06-20 12:24:25,656 [yManager[inbox]] WARN  TemporaryQueueReplyManager     - Exception inside the DMLC for Temporary ReplyTo Queue for destination inbox, refreshing ReplyTo destination
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:431)
        at org.springframework.jms.listener.AbstractPollingMessageListenerContainer.doReceiveAndExecute(AbstractPollingMessageListenerContainer.java:311)
        at org.springframework.jms.listener.AbstractPollingMessageListenerContainer.receiveAndExecute(AbstractPollingMessageListenerContainer.java:264)
        at org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.invokeListener(DefaultMessageListenerContainer.java:1069)
        at org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.executeOngoingLoop(DefaultMessageListenerContainer.java:1061)
        at org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.run(DefaultMessageListenerContainer.java:958)
        at java.lang.Thread.run(Thread.java:662)
2013-06-20 12:24:25,656 [yManager[inbox]] WARN  ultJmsMessageListenerContainer - Setup of JMS message listener invoker failed for destination 'temporary' - trying to recover. Cause: The Consumer is closed
2013-06-20 12:24:25,656 [yManager[inbox]] INFO  PooledConnection               - failed to delete Temporary Queue "temp-queue://ID:xyz-b4be0c20ddf-2115-1371710223718-3:4:1" on closing pooled connection: The connection is already closed
2013-06-20 12:24:25,656 [mer[rtadsinbox]] WARN  ultJmsMessageListenerContainer - Setup of JMS message listener invoker failed for destination 'rtadsinbox' - trying to recover. Cause: The Consumer is closed
2013-06-20 12:24:25,671 [Consumer[inbox]] WARN  ultJmsMessageListenerContainer - Setup of JMS message listener invoker failed for destination 'inbox' - trying to recover. Cause: The Session is closed
2013-06-20 12:24:25,671 [.0.1:2117@61616] WARN  Transport                      - Transport Connection to: tcp://127.0.0.1:2117 failed: java.io.EOFException
2013-06-20 12:24:25,687 [Consumer[inbox]] INFO  ultJmsMessageListenerContainer - Successfully refreshed JMS Connection
2013-06-20 12:24:25,703 [mer[rtadsinbox]] INFO  ultJmsMessageListenerContainer - Successfully refreshed JMS Connection
2013-06-20 12:24:25,703 [yManager[inbox]] INFO  ultJmsMessageListenerContainer - Successfully refreshed JMS Connection
2013-06-20 12:24:25,703 [yManager[inbox]] WARN  TemporaryQueueReplyManager     - Exception inside the DMLC for Temporary ReplyTo Queue for destination inbox, refreshing ReplyTo destination
javax.jms.IllegalStateException: The Session is closed
        at org.apache.activemq.ActiveMQSession.checkClosed(ActiveMQSession.java:731)
        at org.apache.activemq.ActiveMQSession.getTransacted(ActiveMQSession.java:521)
        at org.apache.activemq.pool.PooledSession.getTransacted(PooledSession.java:259)
        at org.springframework.jms.listener.AbstractMessageListenerContainer.commitIfNecessary(AbstractMessageListenerContainer.java:573)
        at org.springframework.jms.listener.AbstractPollingMessageListenerContainer.doReceiveAndExecute(AbstractPollingMessageListenerContainer.java:359)
        at org.springframework.jms.listener.AbstractPollingMessageListenerContainer.receiveAndExecute(AbstractPollingMessageListenerContainer.java:264)
        at org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.invokeListener(DefaultMessageListenerContainer.java:1069)
        at org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.executeOngoingLoop(DefaultMessageListenerContainer.java:1061)
        at org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.run(DefaultMessageListenerContainer.java:958)
        at java.lang.Thread.run(Thread.java:662)
Reply | Threaded
Open this post in threaded view
|

Re: Activemq consumer is closing

ceposta
You should post your connection pool and JmsComponent settings. Are you
using transactions? Are you caching your consumers?


On Thu, Jun 20, 2013 at 2:54 AM, indrayani <[hidden email]> wrote:

> below is the full stack trace
>
>
> 2013-06-20 12:24:25,656 [yManager[inbox]] WARN  TemporaryQueueReplyManager
> - Exception inside the DMLC for Temporary ReplyTo Queue for destination
> inbox, refreshing ReplyTo destination
> 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:431)
>         at
>
> org.springframework.jms.listener.AbstractPollingMessageListenerContainer.doReceiveAndExecute(AbstractPollingMessageListenerContainer.java:311)
>         at
>
> org.springframework.jms.listener.AbstractPollingMessageListenerContainer.receiveAndExecute(AbstractPollingMessageListenerContainer.java:264)
>         at
>
> org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.invokeListener(DefaultMessageListenerContainer.java:1069)
>         at
>
> org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.executeOngoingLoop(DefaultMessageListenerContainer.java:1061)
>         at
>
> org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.run(DefaultMessageListenerContainer.java:958)
>         at java.lang.Thread.run(Thread.java:662)
> 2013-06-20 12:24:25,656 [yManager[inbox]] WARN
> ultJmsMessageListenerContainer - Setup of JMS message listener invoker
> failed for destination 'temporary' - trying to recover. Cause: The Consumer
> is closed
> 2013-06-20 12:24:25,656 [yManager[inbox]] INFO  PooledConnection
> - failed to delete Temporary Queue
> "temp-queue://ID:xyz-b4be0c20ddf-2115-1371710223718-3:4:1" on closing
> pooled
> connection: The connection is already closed
> 2013-06-20 12:24:25,656 [mer[rtadsinbox]] WARN
> ultJmsMessageListenerContainer - Setup of JMS message listener invoker
> failed for destination 'rtadsinbox' - trying to recover. Cause: The
> Consumer
> is closed
> 2013-06-20 12:24:25,671 [Consumer[inbox]] WARN
> ultJmsMessageListenerContainer - Setup of JMS message listener invoker
> failed for destination 'inbox' - trying to recover. Cause: The Session is
> closed
> 2013-06-20 12:24:25,671 [.0.1:2117@61616] WARN  Transport
> - Transport Connection to: tcp://127.0.0.1:2117 failed:
> java.io.EOFException
> 2013-06-20 12:24:25,687 [Consumer[inbox]] INFO
> ultJmsMessageListenerContainer - Successfully refreshed JMS Connection
> 2013-06-20 12:24:25,703 [mer[rtadsinbox]] INFO
> ultJmsMessageListenerContainer - Successfully refreshed JMS Connection
> 2013-06-20 12:24:25,703 [yManager[inbox]] INFO
> ultJmsMessageListenerContainer - Successfully refreshed JMS Connection
> 2013-06-20 12:24:25,703 [yManager[inbox]] WARN  TemporaryQueueReplyManager
> - Exception inside the DMLC for Temporary ReplyTo Queue for destination
> inbox, refreshing ReplyTo destination
> javax.jms.IllegalStateException: The Session is closed
>         at
> org.apache.activemq.ActiveMQSession.checkClosed(ActiveMQSession.java:731)
>         at
> org.apache.activemq.ActiveMQSession.getTransacted(ActiveMQSession.java:521)
>         at
>
> org.apache.activemq.pool.PooledSession.getTransacted(PooledSession.java:259)
>         at
>
> org.springframework.jms.listener.AbstractMessageListenerContainer.commitIfNecessary(AbstractMessageListenerContainer.java:573)
>         at
>
> org.springframework.jms.listener.AbstractPollingMessageListenerContainer.doReceiveAndExecute(AbstractPollingMessageListenerContainer.java:359)
>         at
>
> org.springframework.jms.listener.AbstractPollingMessageListenerContainer.receiveAndExecute(AbstractPollingMessageListenerContainer.java:264)
>         at
>
> org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.invokeListener(DefaultMessageListenerContainer.java:1069)
>         at
>
> org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.executeOngoingLoop(DefaultMessageListenerContainer.java:1061)
>         at
>
> org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.run(DefaultMessageListenerContainer.java:958)
>         at java.lang.Thread.run(Thread.java:662)
>
>
>
> --
> View this message in context:
> http://camel.465427.n5.nabble.com/Activemq-consumer-is-closing-tp5731140p5734413.html
> Sent from the Camel - Users mailing list archive at Nabble.com.
>



--
*Christian Posta*
http://www.christianposta.com/blog
twitter: @christianposta
Reply | Threaded
Open this post in threaded view
|

Re: Activemq consumer is closing

boday
This post was updated on .
In reply to this post by indrayani
we were seeing similar issues and tracked it back to a PooledConnectionFactory idleTimeout issue: https://issues.apache.org/jira/browse/AMQ-4366

the solution for us was to explicitly set the idleTimeout to 0 to disable this ActiveMQMessageConsumer.checkClosed() logic...

indrayani wrote
Hi ,
I understood that these are just warnings ,
but what could be the reason behind getting consumer closed and session closed warnings.
if you check the scenario that i have mentioned , then in that case , 2 web applications are communicating with each other via camel routes which consist of servlet and actimq endpoints,
now in this case , neither of the web application is down, but still after first 2 request-reply , i am getting consumer closed exception for one of the activemq and session closed exception for the other activemq.

I am just curious, why am i not getting the exceptions in the first 2 communictions and why for 3rd ?

it would be really helpful if you elaborate more on this.
Ben O'Day
IT Consultant -http://consulting-notes.com
Reply | Threaded
Open this post in threaded view
|

Re: Activemq consumer is closing

indrayani
thank you so much.
that really helped me, i set the property as follows

<property name="idleTimeout" value="0" />

and now i not facing any exception.

thanks a lottttttttttt, i was badly struggling with this issue since long time.


Regards,
Indrayani
Reply | Threaded
Open this post in threaded view
|

Re: Activemq consumer is closing

indrayani
In reply to this post by indrayani
hi all,
i set the property as follows

<property name="idleTimeout" value="0" />

and now i not facing any exception.

thank you everybody for the support
Reply | Threaded
Open this post in threaded view
|

Re: Activemq consumer is closing

nitinaggarwal
Hi,

I am using apache-activemq-5.14.1 and getting the below issue.

javax.jms.IllegalStateException: The Consumer is closed
        at org.apache.activemq.ActiveMQMessageConsumer.checkClosed(ActiveMQMessageConsumer.java:880)
        at org.apache.activemq.ActiveMQMessageConsumer.receiveNoWait(ActiveMQMessageConsumer.java:678)
        at org.apache.activemq.jms.pool.PooledMessageConsumer.receiveNoWait(PooledMessageConsumer.java:72)
        at com.irdeto.manager.endpoint.activemq.MessageConsumerManager$2.run(MessageConsumerManager.java:105)
        at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
        at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308)
        at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180)
        at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294)
        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
        at java.lang.Thread.run(Thread.java:745)


Can you please tell how did you resolved it or in which file did you make the change.

Thanks in advance
12