activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Jef Gearhart (JIRA)" <j...@apache.org>
Subject [jira] Reopened: (AMQ-734) Network connections do not reconnect when using static: with failover=true
Date Thu, 20 Jul 2006 17:18:24 GMT
     [ https://issues.apache.org/activemq/browse/AMQ-734?page=all ]

Jef Gearhart reopened AMQ-734:
------------------------------

             
Hello,

I can reproduce this issue in the 4.0.1 release.  The test is performed as in the original
post.  I am producing messages to a queue, from a demandForwarding environment.  One possible
difference is the producer is in a stateless session bean under JBoss (ActiveMQ RA version
is 4.0.2).

Here's the output from the broker..
---------------------------------------------------------------------------------------------
D:\ActiveMQ\bin>activemq
ACTIVEMQ_HOME: d:\ActiveMq
Loading message broker from: xbean:activemq.xml
Created MBeanServer with ID: 3dc0bb:10c8cef3623:-8000:fist:1
INFO  JournalPersistenceAdapter      - Journal deleted:
INFO  JDBCPersistenceAdapter         - Database driver recognized: [apache_derby_embedded_jdbc_driver]
INFO  BrokerService                  - ActiveMQ 4.0.1 JMS Message Broker (fist) is starting
INFO  BrokerService                  - For help or more information please see: http://incubator.apache.org/activemq/
RMIConnectorServer started at: service:jmx:rmi://fist/jndi/rmi://localhost:16617/jmxrmi
INFO  ManagementContext              - JMX consoles can connect to service:jmx:rmi://fist/jndi/rmi://localhost:16617/jmxrmi
INFO  JournalPersistenceAdapter      - Journal Recovery Started from: Active Journal: using
5 x 20.0 Megs at: D:\ActiveMQ\activemq-data\journal
INFO  JournalPersistenceAdapter      - Journal Recovered: 0 message(s) in transactions recovered.
INFO  TransportServerThreadSupport   - Listening for connections at: tcp://fist:61616
INFO  TransportConnector             - Connector default Started
INFO  TransportServerThreadSupport   - Listening for connections at: tcp://fist:61613?wireFormat=stomp
INFO  TransportConnector             - Connector stomp Started
INFO  NetworkConnector               - Establishing network connection between from vm://fist?network=true
to failover:tcp://204.62.234.33:61616
INFO  VMTransportFactory             - binding to broker: fist
INFO  TransportConnector             - Connector vm://fist Started
INFO  DemandForwardingBridge         - Starting a network connection between vm://fist#0 and
unconnected has been established.
INFO  NetworkConnector               - Network Connector Burnt Started
INFO  BrokerService                  - ActiveMQ JMS Message Broker (fist, ID:fist-2678-1153415721687-1:0)
started
INFO  DemandForwardingBridge         - Network connection between vm://fist#0 and tcp://204.62.234.33:61616(burnt)
has been established.
WARN  DemandForwardingBridge         - Outbound transport to burnt interrupted ...
INFO  DemandForwardingBridge         - Outbound transport to burnt resumed
INFO  DemandForwardingBridge         - Network connection between vm://fist#0 and tcp://204.62.234.33:61616(burnt)
has been established.
INFO  Service                        - Async error occurred: java.lang.IllegalStateException:
Cannot lookup a consumer from a connection that had not been regis
tered: ID:fist-2678-1153415721687-3:1
java.lang.IllegalStateException: Cannot lookup a consumer from a connection that had not been
registered: ID:fist-2678-1153415721687-3:1
        at org.apache.activemq.broker.AbstractConnection.lookupConnectionState(AbstractConnection.java:223)
        at org.apache.activemq.broker.AbstractConnection.processMessageAck(AbstractConnection.java:356)
        at org.apache.activemq.command.MessageAck.visit(MessageAck.java:178)
        at org.apache.activemq.broker.AbstractConnection.service(AbstractConnection.java:201)
        at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:62)
        at org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:97)
        at org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:63)
        at org.apache.activemq.transport.vm.VMTransport.oneway(VMTransport.java:76)
        at org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:44)
        at org.apache.activemq.transport.ResponseCorrelator.oneway(ResponseCorrelator.java:60)
        at org.apache.activemq.network.DemandForwardingBridgeSupport$5.onCompletion(DemandForwardingBridgeSupport.java:490)
        at org.apache.activemq.transport.FutureResponse.set(FutureResponse.java:59)
        at org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:89)
        at org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:63)
        at org.apache.activemq.transport.failover.FailoverTransport$1.onCommand(FailoverTransport.java:105)
        at org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:114)
        at org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:122)
        at org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:87)
        at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:143)
        at java.lang.Thread.run(Thread.java:534)
WARN  DemandForwardingBridge         - Unexpected local command: ConnectionError {commandId
= 7, responseRequired = false, connectionId = null, exception = java
.lang.IllegalStateException: Cannot lookup a consumer from a connection that had not been
registered: ID:fist-2678-1153415721687-3:1}
INFO  Service                        - Async error occurred: java.lang.IllegalStateException:
Cannot lookup a consumer from a connection that had not been regis
tered: ID:fist-2678-1153415721687-3:1
java.lang.IllegalStateException: Cannot lookup a consumer from a connection that had not been
registered: ID:fist-2678-1153415721687-3:1
        at org.apache.activemq.broker.AbstractConnection.lookupConnectionState(AbstractConnection.java:223)
        at org.apache.activemq.broker.AbstractConnection.processMessageAck(AbstractConnection.java:356)
        at org.apache.activemq.command.MessageAck.visit(MessageAck.java:178)
        at org.apache.activemq.broker.AbstractConnection.service(AbstractConnection.java:201)
        at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:62)
        at org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:97)
        at org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:63)
        at org.apache.activemq.transport.vm.VMTransport.oneway(VMTransport.java:76)
        at org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:44)
        at org.apache.activemq.transport.ResponseCorrelator.oneway(ResponseCorrelator.java:60)
        at org.apache.activemq.network.DemandForwardingBridgeSupport$5.onCompletion(DemandForwardingBridgeSupport.java:490)
        at org.apache.activemq.transport.FutureResponse.set(FutureResponse.java:59)
        at org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:89)
        at org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:63)
        at org.apache.activemq.transport.failover.FailoverTransport$1.onCommand(FailoverTransport.java:105)
        at org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:114)
        at org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:122)
        at org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:87)
        at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:143)
        at java.lang.Thread.run(Thread.java:534)
WARN  DemandForwardingBridge         - Unexpected local command: ConnectionError {commandId
= 8, responseRequired = false, connectionId = null, exception = java
.lang.IllegalStateException: Cannot lookup a consumer from a connection that had not been
registered: ID:fist-2678-1153415721687-3:1}
INFO  Service                        - Async error occurred: java.lang.IllegalStateException:
Cannot lookup a consumer from a connection that had not been regis
tered: ID:fist-2678-1153415721687-3:1
java.lang.IllegalStateException: Cannot lookup a consumer from a connection that had not been
registered: ID:fist-2678-1153415721687-3:1
        at org.apache.activemq.broker.AbstractConnection.lookupConnectionState(AbstractConnection.java:223)
        at org.apache.activemq.broker.AbstractConnection.processMessageAck(AbstractConnection.java:356)
        at org.apache.activemq.command.MessageAck.visit(MessageAck.java:178)
        at org.apache.activemq.broker.AbstractConnection.service(AbstractConnection.java:201)
        at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:62)
        at org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:97)
        at org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:63)
        at org.apache.activemq.transport.vm.VMTransport.oneway(VMTransport.java:76)
        at org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:44)
        at org.apache.activemq.transport.ResponseCorrelator.oneway(ResponseCorrelator.java:60)
        at org.apache.activemq.network.DemandForwardingBridgeSupport$5.onCompletion(DemandForwardingBridgeSupport.java:490)
        at org.apache.activemq.transport.FutureResponse.set(FutureResponse.java:59)
        at org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:89)
        at org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:63)
        at org.apache.activemq.transport.failover.FailoverTransport$1.onCommand(FailoverTransport.java:105)
        at org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:114)
        at org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:122)
        at org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:87)
        at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:143)
        at java.lang.Thread.run(Thread.java:534)
WARN  DemandForwardingBridge         - Unexpected local command: ConnectionError {commandId
= 9, responseRequired = false, connectionId = null, exception = java
.lang.IllegalStateException: Cannot lookup a consumer from a connection that had not been
registered: ID:fist-2678-1153415721687-3:1}


> Network connections do not reconnect when using static: with failover=true
> --------------------------------------------------------------------------
>
>                 Key: AMQ-734
>                 URL: https://issues.apache.org/activemq/browse/AMQ-734
>             Project: ActiveMQ
>          Issue Type: Bug
>          Components: Connector
>    Affects Versions: 4.0
>         Environment: winxp java1.5.6
>            Reporter: tao
>         Assigned To: Hiram Chirino
>            Priority: Critical
>             Fix For: 4.0.1, 4.1
>
>
> If I pull out RJ45 port from net card ,waiting a time ,then put  RJ45 port net card .Network
is resume.Other computer always throw errors and net channel can't work.

-- 
This message is automatically generated by JIRA.
-
If you think it was sent incorrectly contact one of the administrators: https://issues.apache.org/activemq/secure/Administrators.jspa
-
For more information on JIRA, see: http://www.atlassian.com/software/jira

        

Mime
View raw message