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

bodrin do-not-reply at jboss.com
Fri Feb 1 09:40:40 EST 2008


Here are my answers:
anonymous wrote : 
  | I - Have you used debugging during your tests?
  | 
No. I just leave the long-live-consumer to run for a few hours, then check it if it receives the messages. It does not, and then I connect with the debuger to it and try to analyze
its state via suspending all the threads, but withouh any success - I only see two related threads blocked on a socket read operation.

anonymous wrote : 
  | II - Also.. have you seen this sort of message on server?
  | 
  | "16:09:52,005 WARN [SimpleConnectionManager] A problem has been detected with the connection to remote client 3j011-dg4k19-fc3uylzr-1-fc3uymin-4, jmsClientID=b-7omyu3cf-1-rzlyu3cf-91k4gd-110j3. It is possible the client has exited without closing its connection(s) or the network has failed. All connection resources corresponding to that client process will now be removed."
  | 
Yes, when checking question III.

I tried to reproduce it again and there is an exception into the JBoss console:

  | 09:48:07,081 INFO  [Server] JBoss (MX MicroKernel) [4.2.2.GA (build: SVNTag=JBos
  | 
  | [root at centos9 mpay]#
  | [root at centos9 mpay]# 15:31:49,131 ERROR [SocketClientInvoker] Got marshalling exception, exiting
  | java.io.IOException: Connection reset
  |         at java.net.SocketOutputStream.socketWrite(SocketOutputStream.java:96)
  |         at java.net.SocketOutputStream.write(SocketOutputStream.java:136)
  |         at java.io.BufferedOutputStream.flushBuffer(BufferedOutputStream.java:65)
  |         at java.io.BufferedOutputStream.flush(BufferedOutputStream.java:123)
  |         at java.io.DataOutputStream.flush(DataOutputStream.java:106)
  |         at org.jboss.jms.wireformat.ClientDelivery.write(ClientDelivery.java:93)
  |         at org.jboss.jms.wireformat.JMSWireFormat.write(JMSWireFormat.java:237)
  |         at org.jboss.remoting.transport.socket.MicroSocketClientInvoker.versionedWrite(MicroSocketClientInvoker.java:945)
  |         at org.jboss.remoting.transport.socket.MicroSocketClientInvoker.transport(MicroSocketClientInvoker.java:586)
  |         at org.jboss.remoting.transport.bisocket.BisocketClientInvoker.transport(BisocketClientInvoker.java:418)
  |         at org.jboss.remoting.MicroRemoteClientInvoker.invoke(MicroRemoteClientInvoker.java:122)
  |         at org.jboss.remoting.Client.invoke(Client.java:1634)
  |         at org.jboss.remoting.Client.invoke(Client.java:548)
  |         at org.jboss.remoting.Client.invokeOneway(Client.java:598)
  |         at org.jboss.remoting.callback.ServerInvokerCallbackHandler.handleCallback(ServerInvokerCallbackHandler.java:826)
  |         at org.jboss.remoting.callback.ServerInvokerCallbackHandler.handleCallbackOneway(ServerInvokerCallbackHandler.java:697)
  |         at org.jboss.jms.server.endpoint.ServerSessionEndpoint.performDelivery(ServerSessionEndpoint.java:1432)
  |         at org.jboss.jms.server.endpoint.ServerSessionEndpoint.handleDelivery(ServerSessionEndpoint.java:1344)
  |         at org.jboss.jms.server.endpoint.ServerConsumerEndpoint.handle(ServerConsumerEndpoint.java:322)
  |         at org.jboss.messaging.core.impl.RoundRobinDistributor.handle(RoundRobinDistributor.java:119)
  |         at org.jboss.messaging.core.impl.MessagingQueue$DistributorWrapper.handle(MessagingQueue.java:582)
  |         at org.jboss.messaging.core.impl.ClusterRoundRobinDistributor.handle(ClusterRoundRobinDistributor.java:79)
  |         at org.jboss.messaging.core.impl.ChannelSupport.deliverInternal(ChannelSupport.java:606)
  |         at org.jboss.messaging.core.impl.MessagingQueue.deliverInternal(MessagingQueue.java:505)
  |         at org.jboss.messaging.core.impl.ChannelSupport$InMemoryCallback.afterCommit(ChannelSupport.java:935)
  |         at org.jboss.messaging.core.impl.tx.Transaction.commit(Transaction.java:228)
  |         at org.jboss.jms.server.endpoint.ServerConnectionEndpoint.sendTransaction(ServerConnectionEndpoint.java:474)
  |         at org.jboss.jms.server.endpoint.advised.ConnectionAdvised.org$jboss$jms$server$endpoint$advised$ConnectionAdvised$sendTransaction$aop(ConnectionAdvised.java:101)
  |         at org.jboss.jms.server.endpoint.advised.ConnectionAdvised$sendTransaction_N3268650789275322226.invokeNext(ConnectionAdvised$sendTransaction_N3268650789275322226.java)
  |         at org.jboss.jms.server.container.SecurityAspect.handleSendTransaction(SecurityAspect.java:195)
  |         at sun.reflect.GeneratedMethodAccessor86.invoke(Unknown Source)
  |         at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
  |         at java.lang.reflect.Method.invoke(Method.java:597)
  |         at org.jboss.aop.advice.PerInstanceAdvice.invoke(PerInstanceAdvice.java:121)
  |         at org.jboss.jms.server.endpoint.advised.ConnectionAdvised$sendTransaction_N3268650789275322226.invokeNext(ConnectionAdvised$sendTransaction_N3268650789275322226.java)
  |         at org.jboss.jms.server.container.ServerLogInterceptor.invoke(ServerLogInterceptor.java:105)
  |         at org.jboss.jms.server.endpoint.advised.ConnectionAdvised$sendTransaction_N3268650789275322226.invokeNext(ConnectionAdvised$sendTransaction_N3268650789275322226.java)
  |         at org.jboss.jms.server.endpoint.advised.ConnectionAdvised.sendTransaction(ConnectionAdvised.java)
  |         at org.jboss.jms.wireformat.ConnectionSendTransactionRequest.serverInvoke(ConnectionSendTransactionRequest.java:82)
  |         at org.jboss.jms.server.remoting.JMSServerInvocationHandler.invoke(JMSServerInvocationHandler.java:143)
  |         at org.jboss.remoting.ServerInvoker.invoke(ServerInvoker.java:795)
  |         at org.jboss.remoting.transport.socket.ServerThread.processInvocation(ServerThread.java:573)
  |         at org.jboss.remoting.transport.socket.ServerThread.dorun(ServerThread.java:387)
  |         at org.jboss.remoting.transport.socket.ServerThread.run(ServerThread.java:166)
  | 15:31:49,136 ERROR [ServerInvokerCallbackHandler] Error handling callback
  | java.rmi.MarshalException: Failed to communicate.  Problem during marshalling/unmarshalling; nested exception is:
  |         java.io.IOException: Connection reset
  |         at org.jboss.remoting.transport.socket.SocketClientInvoker.handleException(SocketClientInvoker.java:122)
  |         at org.jboss.remoting.transport.socket.MicroSocketClientInvoker.transport(MicroSocketClientInvoker.java:669)
  |         at org.jboss.remoting.transport.bisocket.BisocketClientInvoker.transport(BisocketClientInvoker.java:418)
  |         at org.jboss.remoting.MicroRemoteClientInvoker.invoke(MicroRemoteClientInvoker.java:122)
  |         at org.jboss.remoting.Client.invoke(Client.java:1634)
  |         at org.jboss.remoting.Client.invoke(Client.java:548)
  |         at org.jboss.remoting.Client.invokeOneway(Client.java:598)
  |         at org.jboss.remoting.callback.ServerInvokerCallbackHandler.handleCallback(ServerInvokerCallbackHandler.java:826)
  |         at org.jboss.remoting.callback.ServerInvokerCallbackHandler.handleCallbackOneway(ServerInvokerCallbackHandler.java:697)
  |         at org.jboss.jms.server.endpoint.ServerSessionEndpoint.performDelivery(ServerSessionEndpoint.java:1432)
  |         at org.jboss.jms.server.endpoint.ServerSessionEndpoint.handleDelivery(ServerSessionEndpoint.java:1344)
  |         at org.jboss.jms.server.endpoint.ServerConsumerEndpoint.handle(ServerConsumerEndpoint.java:322)
  |         at org.jboss.messaging.core.impl.RoundRobinDistributor.handle(RoundRobinDistributor.java:119)
  |         at org.jboss.messaging.core.impl.MessagingQueue$DistributorWrapper.handle(MessagingQueue.java:582)
  |         at org.jboss.messaging.core.impl.ClusterRoundRobinDistributor.handle(ClusterRoundRobinDistributor.java:79)
  |         at org.jboss.messaging.core.impl.ChannelSupport.deliverInternal(ChannelSupport.java:606)
  |         at org.jboss.messaging.core.impl.MessagingQueue.deliverInternal(MessagingQueue.java:505)
  |         at org.jboss.messaging.core.impl.ChannelSupport$InMemoryCallback.afterCommit(ChannelSupport.java:935)
  |         at org.jboss.messaging.core.impl.tx.Transaction.commit(Transaction.java:228)
  |         at org.jboss.jms.server.endpoint.ServerConnectionEndpoint.sendTransaction(ServerConnectionEndpoint.java:474)
  |         at org.jboss.jms.server.endpoint.advised.ConnectionAdvised.org$jboss$jms$server$endpoint$advised$ConnectionAdvised$sendTransaction$aop(ConnectionAdvised.java:101)
  |         at org.jboss.jms.server.endpoint.advised.ConnectionAdvised$sendTransaction_N3268650789275322226.invokeNext(ConnectionAdvised$sendTransaction_N3268650789275322226.java)
  |         at org.jboss.jms.server.container.SecurityAspect.handleSendTransaction(SecurityAspect.java:195)
  |         at sun.reflect.GeneratedMethodAccessor86.invoke(Unknown Source)
  |         at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
  |         at java.lang.reflect.Method.invoke(Method.java:597)
  |         at org.jboss.aop.advice.PerInstanceAdvice.invoke(PerInstanceAdvice.java:121)
  |         at org.jboss.jms.server.endpoint.advised.ConnectionAdvised$sendTransaction_N3268650789275322226.invokeNext(ConnectionAdvised$sendTransaction_N3268650789275322226.java)
  |         at org.jboss.jms.server.container.ServerLogInterceptor.invoke(ServerLogInterceptor.java:105)
  |         at org.jboss.jms.server.endpoint.advised.ConnectionAdvised$sendTransaction_N3268650789275322226.invokeNext(ConnectionAdvised$sendTransaction_N3268650789275322226.java)
  |         at org.jboss.jms.server.endpoint.advised.ConnectionAdvised.sendTransaction(ConnectionAdvised.java)
  |         at org.jboss.jms.wireformat.ConnectionSendTransactionRequest.serverInvoke(ConnectionSendTransactionRequest.java:82)
  |         at org.jboss.jms.server.remoting.JMSServerInvocationHandler.invoke(JMSServerInvocationHandler.java:143)
  |         at org.jboss.remoting.ServerInvoker.invoke(ServerInvoker.java:795)
  |         at org.jboss.remoting.transport.socket.ServerThread.processInvocation(ServerThread.java:573)
  |         at org.jboss.remoting.transport.socket.ServerThread.dorun(ServerThread.java:387)
  |         at org.jboss.remoting.transport.socket.ServerThread.run(ServerThread.java:166)
  | Caused by: java.io.IOException: Connection reset
  |         at java.net.SocketOutputStream.socketWrite(SocketOutputStream.java:96)
  |         at java.net.SocketOutputStream.write(SocketOutputStream.java:136)
  |         at java.io.BufferedOutputStream.flushBuffer(BufferedOutputStream.java:65)
  |         at java.io.BufferedOutputStream.flush(BufferedOutputStream.java:123)
  |         at java.io.DataOutputStream.flush(DataOutputStream.java:106)
  |         at org.jboss.jms.wireformat.ClientDelivery.write(ClientDelivery.java:93)
  |         at org.jboss.jms.wireformat.JMSWireFormat.write(JMSWireFormat.java:237)
  |         at org.jboss.remoting.transport.socket.MicroSocketClientInvoker.versionedWrite(MicroSocketClientInvoker.java:945)
  |         at org.jboss.remoting.transport.socket.MicroSocketClientInvoker.transport(MicroSocketClientInvoker.java:586)
  |         ... 35 more
  | [root at centos9 mpay]#
  | 

anonymous wrote : 
  | III - If you start another client, Long-live-queue-consumer, would you see messages arriving?
  | 

1. I have started another client and it received 8 messages, not 10 as espected. Two messages are missing
2. I tried to send another 10 messages and the second long-live-consumers receives them all.
3. I stopped the first one, and then a message into the JBoss console appeared:

  | [root at centos9 mpay]# 15:52:58,801 WARN  [SimpleConnectionManager] A problem has been detected with the connection to remote client 4sg1e4f-d8p38v-fc4foojk-1-fc4fop7g-4, jmsClientID=b-tepof4cf-1-kjoof4cf-v83p8d-f4e1gs4. It is possible the client has exited without closing its connection(s) or the network has failed. All connection resources corresponding to that client process will now be removed.
  | 
Could you tell me what exactly this means, please?
 
4.After that I have started again a long-live-consumer and it received the two missing messages.


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

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



More information about the jboss-user mailing list