You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@activemq.apache.org by "james strachan (JIRA)" <ji...@activemq.org> on 2006/03/17 14:20:26 UTC
[jira] Resolved: (AMQ-602) Remote TCP Publish-only persistant
clients are unable to reconnect when TCP/IP level discconect occurs
[ http://jira.activemq.org/jira//browse/AMQ-602?page=all ]
james strachan resolved AMQ-602:
--------------------------------
Resolution: Fixed
This looks to be the same as AMQ-600
> Remote TCP Publish-only persistant clients are unable to reconnect when TCP/IP level discconect occurs
> ------------------------------------------------------------------------------------------------------
>
> Key: AMQ-602
> URL: http://jira.activemq.org/jira//browse/AMQ-602
> Project: ActiveMQ
> Type: Bug
> Components: Broker
> Versions: 4.0 M4
> Environment: Enterprise class SMP Linux 2.6.12 (Mandriva) with 4GB RAM+ RAID
> J2SDK 1.5_06
> Reporter: John Gorkos
> Assignee: Rob Davies
>
>
> During long-term operation, a remote, publish-only client with a TCP socket connection to the JMS broker will occasionally be disconnected at a low level (i.e. below the application level where JMS runs). When this occurs, the JMS broker throws an exception indicating a broken socket, but does not release the clientID of the client to allow for reconnects. The following stack traces should demonstrate this failure mode:
> INFO Service - Async error occurred: java.net.SocketException: Connection reset
> java.net.SocketException: Connection reset
> at java.net.SocketOutputStream.socketWrite(SocketOutputStream.java:96)
> at java.net.SocketOutputStream.write(SocketOutputStream.java:136)
> at org.apache.activemq.transport.tcp.TcpBufferedOutputStream.flush(TcpBufferedOutputStream.java:108)
> at java.io.DataOutputStream.flush(DataOutputStream.java:106)
> at org.apache.activemq.transport.tcp.TcpTransport.oneway(TcpTransport.java:118)
> at org.apache.activemq.transport.TransportFilter.oneway(TransportFilter.java:90)
> at org.apache.activemq.transport.WireFormatNegotiator.oneway(WireFormatNegotiator.java:65)
> at org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:44)
> at org.apache.activemq.transport.ResponseCorrelator.oneway(ResponseCorrelator.java:54)
> at org.apache.activemq.broker.TransportConnection.dispatch(TransportConnection.java:212)
> at org.apache.activemq.broker.AbstractConnection.dispatchSync(AbstractConnection.java:517)
> at org.apache.activemq.broker.AbstractConnection.dispatchAsync(AbstractConnection.java:535)
> at org.apache.activemq.broker.region.TopicSubscription.dispatch(TopicSubscription.java:142)
> at org.apache.activemq.broker.region.TopicSubscription.add(TopicSubscription.java:54)
> at org.apache.activemq.broker.region.policy.SimpleDispatchPolicy.dispatch(SimpleDispatchPolicy.java:50)
> at org.apache.activemq.broker.region.Topic.dispatch(Topic.java:365)
> at org.apache.activemq.broker.region.Topic.send(Topic.java:247)
> at org.apache.activemq.broker.region.AbstractRegion.send(AbstractRegion.java:195)
> at org.apache.activemq.broker.region.RegionBroker.send(RegionBroker.java:312)
> at org.apache.activemq.broker.TransactionBroker.send(TransactionBroker.java:192)
> at org.apache.activemq.broker.BrokerFilter.send(BrokerFilter.java:107)
> at org.apache.activemq.broker.CompositeDestinationBroker.send(CompositeDestinationBroker.java:97)
> at org.apache.activemq.broker.MutableBrokerFilter.send(MutableBrokerFilter.java:119)
> at org.apache.activemq.broker.AbstractConnection.processMessage(AbstractConnection.java:336)
> at org.apache.activemq.command.ActiveMQMessage.visit(ActiveMQMessage.java:508)
> at org.apache.activemq.broker.AbstractConnection.service(AbstractConnection.java:189)
> at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:60)
> at org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:82)
> at org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:68)
> at org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:105)
> at org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:77)
> at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:136)
> at java.lang.Thread.run(Thread.java:595)
> ACTIVEMQ_HOME: /opt/activemq
> Loading message broker from: xbean:activemq.xml
> INFO BrokerService - ActiveMQ 4.0-M4 JMS Message Broker (localhost) is starting
> INFO BrokerService - For help or more information please see: http://www.logicblaze.com
> INFO JDBCPersistenceAdapter - Database driver recognized: [apache_derby_embedded_jdbc_driver]
> INFO JournalPersistenceAdapter - Journal Recovery Started from: Active Journal: using 5 x 20.0 Megs at: ../activemq-data/journal
> INFO JournalPersistenceAdapter - Journal Recovered: 0 message(s) in transactions recovered.
> INFO TransportServerThreadSupport - Listening for connections at: tcp://s1:61616
> INFO TransportConnector - Accepting connection on: tcp://s1:61616
> WARN MulticastDiscoveryAgent - brokerName not set
> INFO TransportServerThreadSupport - Listening for connections at: tcp://s1:61617?wireFormat=stomp
> INFO TransportConnector - Accepting connection on: tcp://s1:61617?wireFormat=stomp
> INFO BrokerService - ActiveMQ JMS Message Broker (localhost) started
> INFO NetworkConnector - Establishing network connection between vm://localhost?network=true and null at failover:tcp://s1:61616
> INFO VMTransportFactory - binding to broker: localhost
> INFO TransportConnector - Accepting connection on: vm://localhost
> INFO DemandForwardingBridge - Starting a network connection between vm://localhost#0 and unconnected has been established.
> INFO ManagementContext - JMX consoles can connect to service:jmx:rmi:///jndi/rmi://localhost:1099/jmxrmi
> INFO DemandForwardingBridge - Disconnecting loop back connection.
> INFO Service - Sync error occurred: javax.jms.InvalidClientIDException: Broker: localhost - Client: TESTClient already connected
> javax.jms.InvalidClientIDException: Broker: localhost - Client: TESTClient already connected
> at org.apache.activemq.broker.region.RegionBroker.addConnection(RegionBroker.java:153)
> at org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:63)
> at org.apache.activemq.advisory.AdvisoryBroker.addConnection(AdvisoryBroker.java:66)
> at org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:63)
> at org.apache.activemq.broker.MutableBrokerFilter.addConnection(MutableBrokerFilter.java:75)
> at org.apache.activemq.broker.AbstractConnection.processAddConnection(AbstractConnection.java:478)
> at org.apache.activemq.broker.jmx.ManagedTransportConnection.processAddConnection(ManagedTransportConnection.java:82)
> at org.apache.activemq.command.ConnectionInfo.visit(ConnectionInfo.java:106)
> at org.apache.activemq.broker.AbstractConnection.service(AbstractConnection.java:189)
> at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:60)
> at org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:82)
> at org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:68)
> at org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:105)
> at org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:77)
> at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:136)
> at java.lang.Thread.run(Thread.java:595)
> INFO Service - Sync error occurred: javax.jms.InvalidClientIDException: Broker: localhost - Client: TESTClient already connected
> javax.jms.InvalidClientIDException: Broker: localhost - Client: TESTClient already connected
> at org.apache.activemq.broker.region.RegionBroker.addConnection(RegionBroker.java:153)
> at org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:63)
> at org.apache.activemq.advisory.AdvisoryBroker.addConnection(AdvisoryBroker.java:66)
> at org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:63)
> at org.apache.activemq.broker.MutableBrokerFilter.addConnection(MutableBrokerFilter.java:75)
> at org.apache.activemq.broker.AbstractConnection.processAddConnection(AbstractConnection.java:478)
> at org.apache.activemq.broker.jmx.ManagedTransportConnection.processAddConnection(ManagedTransportConnection.java:82)
> at org.apache.activemq.command.ConnectionInfo.visit(ConnectionInfo.java:106)
> at org.apache.activemq.broker.AbstractConnection.service(AbstractConnection.java:189)
> at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:60)
> at org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:82)
> at org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:68)
> at org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:105)
> at org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:77)
> at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:136)
> at java.lang.Thread.run(Thread.java:595)
> INFO VMTransportFactory - Shutting down VM connectors for broker: localhost
> INFO VMTransportFactory - Shutting down VM connectors for broker: localhost
> INFO Service - Async error occurred: java.io.EOFException: Cannot write to the stream any more it has already been closed
> java.io.EOFException: Cannot write to the stream any more it has already been closed
> at org.apache.activemq.transport.tcp.TcpBufferedOutputStream.checkClosed(TcpBufferedOutputStream.java:131)
> at org.apache.activemq.transport.tcp.TcpBufferedOutputStream.write(TcpBufferedOutputStream.java:69)
> at java.io.DataOutputStream.writeInt(DataOutputStream.java:180)
> at org.apache.activemq.openwire.OpenWireFormat.marshal(OpenWireFormat.java:169)
> at org.apache.activemq.transport.tcp.TcpTransport.oneway(TcpTransport.java:117)
> at org.apache.activemq.transport.TransportFilter.oneway(TransportFilter.java:90)
> at org.apache.activemq.transport.WireFormatNegotiator.oneway(WireFormatNegotiator.java:65)
> at org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:44)
> at org.apache.activemq.transport.ResponseCorrelator.oneway(ResponseCorrelator.java:54)
> at org.apache.activemq.broker.TransportConnection.dispatch(TransportConnection.java:212)
> at org.apache.activemq.broker.AbstractConnection.dispatchSync(AbstractConnection.java:517)
> at org.apache.activemq.broker.AbstractConnection.dispatchAsync(AbstractConnection.java:535)
> at org.apache.activemq.broker.region.TopicSubscription.dispatch(TopicSubscription.java:142)
> at org.apache.activemq.broker.region.TopicSubscription.add(TopicSubscription.java:54)
> at org.apache.activemq.broker.region.policy.SimpleDispatchPolicy.dispatch(SimpleDispatchPolicy.java:50)
> at org.apache.activemq.broker.region.Topic.dispatch(Topic.java:365)
> at org.apache.activemq.broker.region.Topic.send(Topic.java:247)
> at org.apache.activemq.broker.region.AbstractRegion.send(AbstractRegion.java:195)
> at org.apache.activemq.broker.region.RegionBroker.send(RegionBroker.java:312)
> at org.apache.activemq.broker.TransactionBroker.send(TransactionBroker.java:192)
> at org.apache.activemq.broker.BrokerFilter.send(BrokerFilter.java:107)
> at org.apache.activemq.broker.CompositeDestinationBroker.send(CompositeDestinationBroker.java:97)
> at org.apache.activemq.broker.MutableBrokerFilter.send(MutableBrokerFilter.java:119)
> at org.apache.activemq.broker.AbstractConnection.processMessage(AbstractConnection.java:336)
> at org.apache.activemq.command.ActiveMQMessage.visit(ActiveMQMessage.java:508)
> at org.apache.activemq.broker.AbstractConnection.service(AbstractConnection.java:189)
> at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:60)
> at org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:82)
> at org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:68)
> at org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:105)
> at org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:77)
> at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:136)
> at java.lang.Thread.run(Thread.java:595)
> Reverting to "anonymous" clients allows the client to create a new connection, but further persistant connections from the initial clientId cannot be made until the broker is restarted.
> Please contact via email: johng@amdswireless.com for additional information, if needed.
--
This message is automatically generated by JIRA.
-
If you think it was sent incorrectly contact one of the administrators:
http://jira.activemq.org/jira//secure/Administrators.jspa
-
For more information on JIRA, see:
http://www.atlassian.com/software/jira