You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ch...@apache.org on 2009/12/17 21:46:14 UTC
svn commit: r891888 -
/activemq/sandbox/activemq-apollo-actor/activemq-queue/src/test/java/org/apache/activemq/queue/actor/perf/MockBroker.java
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() {
}