svn commit: r630136 - in /activemq/trunk/activemq-core/src/main/java/org/apache/activemq: ActiveMQConnection.java transport/failover/FailoverTransport.java

[rajdavies]

Author: rajdavies
Date: Fri Feb 22 02:05:33 2008
New Revision: 630136

URL: http://svn.apache.org/viewvc?rev=630136&view=rev
Log:
expose some methods to make it easier to test

Modified:
    
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java
    
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java

Modified: 
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java
URL: 
http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java?rev=630136&r1=630135&r2=630136&view=diff
==============================================================================
--- 
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java
 (original)
+++ 
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java
 Fri Feb 22 02:05:33 2008
@@ -1517,7 +1517,7 @@
     }
 
     // Package protected so that it can be used in unit tests
-    Transport getTransport() {
+    public Transport getTransport() {
         return transport;
     }
 

Modified: 
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java
URL: 
http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java?rev=630136&r1=630135&r2=630136&view=diff
==============================================================================
--- 
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java
 (original)
+++ 
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java
 Fri Feb 22 02:05:33 2008
@@ -32,11 +32,10 @@
 
 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 @@
     }
 
 
-    final void handleTransportFailure(IOException e) throws 
InterruptedException {
+    public final void handleTransportFailure(IOException e) throws 
InterruptedException {
         if (transportListener != null) {
             transportListener.transportInterupted();
         }