[jboss-user] [JBoss Messaging Users] - Re: long live consumer stops working

[PoonamAgarwal]

Hi bodrin,

I am facing a similar issue of connection getting invalidated. 
I am using JBM 1.4.0 SP3 and Jboss 4.20GA.
I have a consumer(client) created for a queue(on server).
I am successful in creating a connection and my consumer does receive messages. However, If I leave my server and consumer for sometime may be some(2-4) hours, I see a log trace in my client: 


  | [21 Sep 2009 15:24:02] DEBUG [Timer-3] (ConnectionValidator.java:674) - ConnectionValidator[SocketClientInvoker[1017ca1, bisocket://myserver:4457], pingPeriod=2000 ms]'s connections is invalid
  | [21 Sep 2009 15:24:02] DEBUG [Timer-3] (InvokerRegistry.java:628) - removed SocketClientInvoker[1017ca1, bisocket://myserver:4457] from registry
  | [21 Sep 2009 15:24:02] DEBUG [Timer-3] (MicroSocketClientInvoker.java:384) - SocketClientInvoker[1017ca1, bisocket://myserver:4457] disconnecting ...
  | [21 Sep 2009 15:24:02] DEBUG [Timer-3] (SocketWrapper.java:127) - ClientSocketWrapper[Socket[addr=/myserver,port=4457,localport=4198].7f6b72] closing socket
  | [21 Sep 2009 15:24:02] DEBUG [Timer-3] (SocketWrapper.java:129) - ClientSocketWrapper[Socket[addr=/myserver,port=4457,localport=4198].7f6b72] closed socket
  | [21 Sep 2009 15:24:02] DEBUG [Timer-3] (SocketWrapper.java:127) - ClientSocketWrapper[Socket[addr=/myserver,port=4446,localport=4197].1673ef7] closing socket
  | [21 Sep 2009 15:24:02] DEBUG [Timer-3] (SocketWrapper.java:129) - ClientSocketWrapper[Socket[addr=/myserver,port=4446,localport=4197].1673ef7] closed socket
  | [21 Sep 2009 15:24:02] DEBUG [Timer-3] (SocketWrapper.java:127) - ClientSocketWrapper[Socket[addr=/myserver,port=4457,localport=4199].156cce6] closing socket
  | [21 Sep 2009 15:24:02] DEBUG [Timer-3] (SocketWrapper.java:129) - ClientSocketWrapper[Socket[addr=/myserver,port=4457,localport=4199].156cce6] closed socket
  | [21 Sep 2009 15:24:02] DEBUG [Timer-3] (ConnectionValidator.java:616) - ConnectionValidator[SocketClientInvoker[1017ca1, bisocket://myserver:4457], pingPeriod=2000 ms] stopped, returning true
  | [21 Sep 2009 15:24:02] DEBUG [Timer-3] (ConnectionValidator.java:680) - org.jboss.remoting.ConnectionValidator$WaitOnConnectionCheckTimerTask at 1a62f80 detected connection failure: stopping LeasePinger
  | [21 Sep 2009 15:24:02] DEBUG [Timer-3] (LeasePinger.java:285) - LeasePinger[SocketClientInvoker[4bb369, bisocket://myserver:4457](4ss82w-n3gywx-fzvb4aaz-1-fzvb4cgo-c)] setting disconnect timeout to: -1
  | [21 Sep 2009 15:24:02] DEBUG [Timer-3] (ConnectionValidator.java:686) - ConnectionValidator[SocketClientInvoker[1017ca1, bisocket://myserver:4457], pingPeriod=2000 ms] shut down lease pinger
  | [21 Sep 2009 15:24:07] DEBUG [Thread-11] (ClientSocketWrapper.java:164) - reset timeout: 0
  | 


This kills my consumer which will no longer receive any messages from the server. How do I solve this problem?
1. How do I create a long live consumer in first place? I could not visit the examples sent by bodrin.
2. Should I listen for such disconnects and try to re-establish the connection on such disconnect? Where should I catch the disconnect exception?
3. What am I missing here?

Can somebody please help.
-Poonam.

View the original post : http://www.jboss.org/index.html?module=bb&op=viewtopic&p=4256352#4256352

Reply to the post : http://www.jboss.org/index.html?module=bb&op=posting&mode=reply&p=4256352