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

don't want errors from old transport after its failed 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@637883 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Robert Davies 2008-03-17 13:34:11 +00:00
parent 4032a01c17
commit 70511a6929
1 changed files with 7 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java
View File

@ -42,6 +42,7 @@ import org.apache.activemq.thread.DefaultThreadPools;
import org.apache.activemq.thread.Task; import org.apache.activemq.thread.Task;
import org.apache.activemq.thread.TaskRunner; import org.apache.activemq.thread.TaskRunner;
import org.apache.activemq.transport.CompositeTransport; import org.apache.activemq.transport.CompositeTransport;
import org.apache.activemq.transport.DefaultTransportListener;
import org.apache.activemq.transport.FutureResponse; import org.apache.activemq.transport.FutureResponse;
import org.apache.activemq.transport.ResponseCallback; import org.apache.activemq.transport.ResponseCallback;
import org.apache.activemq.transport.Transport; import org.apache.activemq.transport.Transport;
@ -97,6 +98,7 @@ public class FailoverTransport implements CompositeTransport {
private int backupPoolSize=1; private int backupPoolSize=1;
private boolean trackMessages = false; private boolean trackMessages = false;
private int maxCacheSize = 128 * 1024; private int maxCacheSize = 128 * 1024;
private TransportListener disposedListener = new DefaultTransportListener();
private final TransportListener myTransportListener = createTransportListener(); private final TransportListener myTransportListener = createTransportListener();
@ -214,6 +216,11 @@ public class FailoverTransport implements CompositeTransport {
wasConnected=true; wasConnected=true;
initialized = false; initialized = false;
failedConnectTransportURI=connectedTransportURI; failedConnectTransportURI=connectedTransportURI;
Transport old = connectedTransport.get();
if(old != null) {
//don't want errors from old transport
old.setTransportListener(disposedListener);
}
connectedTransport.set(null); connectedTransport.set(null);
connectedTransportURI = null; connectedTransportURI = null;
connected=false; connected=false;