From 4fcacf7772205fc36d9bbb55413aed615dd2be5c Mon Sep 17 00:00:00 2001 From: "Hiram R. Chirino" Date: Tue, 11 Mar 2008 19:11:51 +0000 Subject: [PATCH] A client should connect to the same broker for it's sending and receiving so that the broker does the forwarding git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@636064 13f79535-47bb-0310-9956-ffa450edef68 --- .../test/java/org/apache/activemq/network/NetworkLoadTest.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/activemq-core/src/test/java/org/apache/activemq/network/NetworkLoadTest.java b/activemq-core/src/test/java/org/apache/activemq/network/NetworkLoadTest.java index d84b860e63..5a20ffe683 100644 --- a/activemq-core/src/test/java/org/apache/activemq/network/NetworkLoadTest.java +++ b/activemq-core/src/test/java/org/apache/activemq/network/NetworkLoadTest.java @@ -79,7 +79,7 @@ public class NetworkLoadTest extends TestCase { private final Connection fromConnection; public ForwardingClient(int from, int to) throws JMSException { - toConnection = createConnection(to); + toConnection = createConnection(from); Session toSession = toConnection.createSession(false, Session.AUTO_ACKNOWLEDGE); final MessageProducer producer = toSession.createProducer(new ActiveMQQueue("Q"+to)); producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);