activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rajdav...@apache.org
Subject svn commit: r630136 - in /activemq/trunk/activemq-core/src/main/java/org/apache/activemq: ActiveMQConnection.java transport/failover/FailoverTransport.java
Date Fri, 22 Feb 2008 10:05:35 GMT
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();
         }



Mime
View raw message