[ 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
