/[Apache-SVN]
ViewVC logotype

Revision 560872


Jump to revision: Previous Next
Author: chirino
Date: Mon Jul 30 05:34:37 2007 UTC (17 years, 2 months ago)
Changed paths: 8
Log Message:
Serveral changes needed to Fix https://issues.apache.org/activemq/browse/AMQ-1349
 - The vm:// transport was delivering events to the listener before start() was called.  Also clean it up a little by consolidating
   the use of the prePeerSetQueue and messageQueue field.
 - the tcp:// .stop() method now blocks until the thread that calls out to the listener is shutdown.
 - TransportConnection was not doing a good job synchronizing when multiple concurrent conenctions to the same connection Id was established.
   IllegalStateExceptions were common when a failover connection reconnected.  Now we make sure that only 1 connection with a given connectionId
   is activley operating in the broker.  Also removed 1 un-needed hash lookup by replacing the brokerConnectionStates Map with the 
   connectionState variable.
    
Also added a pause in the JmsTempDestinationTest to avoid intermitent failures.



Changed paths

Path Details
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/ConnectionContext.java modified , text changed
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnection.java modified , text changed
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/jmx/ManagedTransportConnection.java modified , text changed
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/RegionBroker.java modified , text changed
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/state/ConnectionState.java modified , text changed
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/tcp/TcpTransport.java modified , text changed
Directoryactivemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/vm/VMTransport.java modified , text changed
Directoryactivemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTempDestinationTest.java modified , text changed

infrastructure at apache.org
ViewVC Help
Powered by ViewVC 1.1.26