Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

http://issues.apache.org/activemq/browse/AMQ-789 

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/branches/activemq-4.0@423792 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Hiram R. Chirino 2006-07-20 06:03:45 +00:00
parent bd37ac540a
commit c59908b429
1 changed files with 13 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
activemq-core/src/main/java/org/apache/activemq/transport/WireFormatNegotiator.java
View File

@ -26,6 +26,7 @@ import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import edu.emory.mathcs.backport.java.util.concurrent.CountDownLatch;
import edu.emory.mathcs.backport.java.util.concurrent.TimeUnit;
import edu.emory.mathcs.backport.java.util.concurrent.atomic.AtomicBoolean;
@ -35,6 +36,7 @@ public class WireFormatNegotiator extends TransportFilter {
private OpenWireFormat wireFormat;
private final int minimumVersion;
private long negotiateTimeout=15000;
private final AtomicBoolean firstStart=new AtomicBoolean(true);
private final CountDownLatch readyCountDownLatch = new CountDownLatch(1);
@ -75,7 +77,8 @@ public class WireFormatNegotiator extends TransportFilter {
public void oneway(Command command) throws IOException {
try {
readyCountDownLatch.await();
if( !readyCountDownLatch.await(negotiateTimeout, TimeUnit.MILLISECONDS) )
throw new IOException("Wire format negociation timeout: peer did not send his wire format.");
} catch (InterruptedException e) {
throw new InterruptedIOException();
}
@ -135,4 +138,13 @@ public class WireFormatNegotiator extends TransportFilter {
protected void onWireFormatNegotiated(WireFormatInfo info) {
}
public long getNegotiateTimeout() {
return negotiateTimeout;
}
public void setNegotiateTimeout(long negotiateTimeout) {
this.negotiateTimeout = negotiateTimeout;
}
}