From b34f7302313bf91a2828173d0a9bf6a2c18c2d0b Mon Sep 17 00:00:00 2001
From: Robert Davies <rajdavies@apache.org>
Date: Fri, 22 Feb 2008 10:05:33 +0000
Subject: [PATCH] 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
---
 .../main/java/org/apache/activemq/ActiveMQConnection.java    | 2 +-
 .../activemq/transport/failover/FailoverTransport.java       | 5 ++---
 2 files changed, 3 insertions(+), 4 deletions(-)

diff --git a/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java b/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java
index 6f7fbf218b..d21ccdc7d1 100755
--- a/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java
+++ b/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java
@@ -1517,7 +1517,7 @@ public class ActiveMQConnection implements Connection, TopicConnection, QueueCon
     }
 
     // Package protected so that it can be used in unit tests
-    Transport getTransport() {
+    public Transport getTransport() {
         return transport;
     }
 
diff --git a/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java b/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java
index f132b397bf..ab982a3f62 100755
--- a/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java
+++ b/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java
@@ -32,11 +32,10 @@ import java.util.concurrent.ThreadFactory;
 
 import org.apache.activemq.command.BrokerInfo;
 import org.apache.activemq.command.Command;
-import org.apache.activemq.command.Response;
 import org.apache.activemq.command.RemoveInfo;
+import org.apache.activemq.command.Response;
 import org.apache.activemq.state.ConnectionStateTracker;
 import org.apache.activemq.state.Tracked;
-import org.apache.activemq.thread.DefaultThreadPools;
 import org.apache.activemq.thread.DeterministicTaskRunner;
 import org.apache.activemq.thread.Task;
 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) {
             transportListener.transportInterupted();
         }