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

expose some methods to make it easier to test 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@630136 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Robert Davies 2008-02-22 10:05:33 +00:00
parent 3d33c0e51a
commit b34f730231
2 changed files with 3 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java
View File

@ -1517,7 +1517,7 @@ public class ActiveMQConnection implements Connection, TopicConnection, QueueCon
} }
// Package protected so that it can be used in unit tests // Package protected so that it can be used in unit tests
Transport getTransport() { public Transport getTransport() {
return transport; return transport;
} }

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

@ -32,11 +32,10 @@ import java.util.concurrent.ThreadFactory;
import org.apache.activemq.command.BrokerInfo; import org.apache.activemq.command.BrokerInfo;
import org.apache.activemq.command.Command; import org.apache.activemq.command.Command;
import org.apache.activemq.command.Response;
import org.apache.activemq.command.RemoveInfo; import org.apache.activemq.command.RemoveInfo;
import org.apache.activemq.command.Response;
import org.apache.activemq.state.ConnectionStateTracker; import org.apache.activemq.state.ConnectionStateTracker;
import org.apache.activemq.state.Tracked; import org.apache.activemq.state.Tracked;
import org.apache.activemq.thread.DefaultThreadPools;
import org.apache.activemq.thread.DeterministicTaskRunner; import org.apache.activemq.thread.DeterministicTaskRunner;
import org.apache.activemq.thread.Task; import org.apache.activemq.thread.Task;
import org.apache.activemq.thread.TaskRunner; import org.apache.activemq.thread.TaskRunner;
@ -191,7 +190,7 @@ public class FailoverTransport implements CompositeTransport {
} }
final void handleTransportFailure(IOException e) throws InterruptedException { public final void handleTransportFailure(IOException e) throws InterruptedException {
if (transportListener != null) { if (transportListener != null) {
transportListener.transportInterupted(); transportListener.transportInterupted();
} }