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);