diff options
Diffstat (limited to 'java/cluster/src/test')
| -rw-r--r-- | java/cluster/src/test/java/org/apache/qpid/server/cluster/BrokerTest.java | 12 |
1 files changed, 6 insertions, 6 deletions
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<AMQDataBlock> 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<AMQDataBlock> 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()); |