You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ch...@apache.org on 2006/07/20 07:45:32 UTC
svn commit: r423784 -
/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/WireFormatNegotiator.java
Author: chirino
Date: Wed Jul 19 22:45:32 2006
New Revision: 423784
URL: http://svn.apache.org/viewvc?rev=423784&view=rev
Log:
http://issues.apache.org/activemq/browse/AMQ-789
Modified:
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/WireFormatNegotiator.java
Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/WireFormatNegotiator.java
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/WireFormatNegotiator.java?rev=423784&r1=423783&r2=423784&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/WireFormatNegotiator.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/WireFormatNegotiator.java Wed Jul 19 22:45:32 2006
@@ -70,6 +70,11 @@
}
}
+ public void stop() throws Exception {
+ super.stop();
+ readyCountDownLatch.countDown();
+ }
+
public void oneway(Command command) throws IOException {
try {
if( !readyCountDownLatch.await(negotiateTimeout, TimeUnit.MILLISECONDS) )