activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r891888 - /activemq/sandbox/activemq-apollo-actor/activemq-queue/src/test/java/org/apache/activemq/queue/actor/perf/MockBroker.java
Date Thu, 17 Dec 2009 20:46:14 GMT
Author: chirino
Date: Thu Dec 17 20:46:13 2009
New Revision: 891888

URL: http://svn.apache.org/viewvc?rev=891888&view=rev
Log:
dont start the connection until after the connector is bound

Modified:
    activemq/sandbox/activemq-apollo-actor/activemq-queue/src/test/java/org/apache/activemq/queue/actor/perf/MockBroker.java

Modified: activemq/sandbox/activemq-apollo-actor/activemq-queue/src/test/java/org/apache/activemq/queue/actor/perf/MockBroker.java
URL: http://svn.apache.org/viewvc/activemq/sandbox/activemq-apollo-actor/activemq-queue/src/test/java/org/apache/activemq/queue/actor/perf/MockBroker.java?rev=891888&r1=891887&r2=891888&view=diff
==============================================================================
--- activemq/sandbox/activemq-apollo-actor/activemq-queue/src/test/java/org/apache/activemq/queue/actor/perf/MockBroker.java
(original)
+++ activemq/sandbox/activemq-apollo-actor/activemq-queue/src/test/java/org/apache/activemq/queue/actor/perf/MockBroker.java
Thu Dec 17 20:46:13 2009
@@ -96,18 +96,17 @@
         transportServer.setTargetQueue(brokerDispatchQueue);
         transportServer.setHandler(this);
         transportServer.resume();
-
+        
         for (MockQueue queue : queues.values()) {
             queue.start();
         }
+    }
 
+    public void onBind() {
         for (BrokerConnection connection : brokerConnections) {
             connection.retain();
         }
     }
-
-    public void onBind() {
-    }
     
     public void onUnbind() {
     }



Mime
View raw message