From 2adb6491718aca37a808a57e2ad530e9a0a5ab2d Mon Sep 17 00:00:00 2001 From: Robert Greig Date: Mon, 29 Jan 2007 11:10:09 +0000 Subject: QPID-320 : Patch supplied by Rob Godfrey - Improve performance by remembering protocol version git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@501009 13f79535-47bb-0310-9956-ffa450edef68 --- .../test/java/org/apache/qpid/server/cluster/BrokerTest.java | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) (limited to 'java/cluster/src/test') diff --git a/java/cluster/src/test/java/org/apache/qpid/server/cluster/BrokerTest.java b/java/cluster/src/test/java/org/apache/qpid/server/cluster/BrokerTest.java index 20e092bde7..f1da312eea 100644 --- a/java/cluster/src/test/java/org/apache/qpid/server/cluster/BrokerTest.java +++ b/java/cluster/src/test/java/org/apache/qpid/server/cluster/BrokerTest.java @@ -54,7 +54,7 @@ public class BrokerTest extends TestCase for (RecordingBroker b : brokers) { - b.handleResponse(((AMQFrame) b.getMessages().get(0)).channel, new TestMethod("response")); + b.handleResponse(((AMQFrame) b.getMessages().get(0)).getChannel(), new TestMethod("response")); } assertTrue("Handler did not receive response", handler.isCompleted()); @@ -80,7 +80,7 @@ public class BrokerTest extends TestCase for (RecordingBroker broker : succeeded) { - broker.handleResponse(((AMQFrame) broker.getMessages().get(0)).channel, new TestMethod("response")); + broker.handleResponse(((AMQFrame) broker.getMessages().get(0)).getChannel(), new TestMethod("response")); } b.remove(); @@ -106,7 +106,7 @@ public class BrokerTest extends TestCase for (int i = 0; i < msgs.length; i++) { assertTrue(sent.get(i) instanceof AMQFrame); - assertEquals(msgs[i], ((AMQFrame) sent.get(i)).bodyFrame); + assertEquals(msgs[i], ((AMQFrame) sent.get(i)).getBodyFrame()); } } @@ -119,9 +119,9 @@ public class BrokerTest extends TestCase List sent = broker.getMessages(); assertEquals(1, sent.size()); assertTrue(sent.get(0) instanceof AMQFrame); - assertEquals(new TestMethod("A"), ((AMQFrame) sent.get(0)).bodyFrame); + assertEquals(new TestMethod("A"), ((AMQFrame) sent.get(0)).getBodyFrame()); - broker.handleResponse(((AMQFrame) sent.get(0)).channel, new TestMethod("B")); + broker.handleResponse(((AMQFrame) sent.get(0)).getChannel(), new TestMethod("B")); assertEquals(new TestMethod("B"), handler.getResponse()); } @@ -135,7 +135,7 @@ public class BrokerTest extends TestCase List sent = broker.getMessages(); assertEquals(1, sent.size()); assertTrue(sent.get(0) instanceof AMQFrame); - assertEquals(new TestMethod("A"), ((AMQFrame) sent.get(0)).bodyFrame); + assertEquals(new TestMethod("A"), ((AMQFrame) sent.get(0)).getBodyFrame()); broker.remove(); assertEquals(null, handler.getResponse()); assertTrue(handler.isCompleted()); -- cgit v1.2.1