diff options
Diffstat (limited to 'java/cluster/src/test')
3 files changed, 18 insertions, 18 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 f1da312eea..ad7d7e1b5f 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 @@ -23,11 +23,11 @@ package org.apache.qpid.server.cluster; import junit.framework.TestCase; import org.apache.mina.common.ByteBuffer; import org.apache.qpid.AMQException; -import org.apache.qpid.framing.AMQBody; +import org.apache.qpid.framing.AMQBodyImpl; import org.apache.qpid.framing.AMQDataBlock; import org.apache.qpid.framing.AMQFrame; import org.apache.qpid.framing.AMQFrameDecodingException; -import org.apache.qpid.framing.AMQMethodBody; +import org.apache.qpid.framing.AMQMethodBodyImpl; import org.apache.qpid.server.cluster.policy.StandardPolicies; import java.util.ArrayList; @@ -91,13 +91,13 @@ public class BrokerTest extends TestCase //simple send (no response) public void testSend_noResponse() throws AMQException { - AMQBody[] msgs = new AMQBody[]{ + AMQBodyImpl[] msgs = new AMQBodyImpl[]{ new TestMethod("A"), new TestMethod("B"), new TestMethod("C") }; RecordingBroker broker = new RecordingBroker("myhost", 1); - for (AMQBody msg : msgs) + for (AMQBodyImpl msg : msgs) { broker.send(new SimpleBodySendable(msg), null); } @@ -142,7 +142,7 @@ public class BrokerTest extends TestCase assertTrue(handler.failed()); } - private static class TestMethod extends AMQMethodBody + private static class TestMethod extends AMQMethodBodyImpl { private final Object id; @@ -209,19 +209,19 @@ public class BrokerTest extends TestCase private static class GroupResponseValidator implements GroupResponseHandler { - private final AMQMethodBody _response; + private final AMQMethodBodyImpl _response; private final List<Member> _members; private boolean _completed = false; - GroupResponseValidator(AMQMethodBody response, List<Member> members) + GroupResponseValidator(AMQMethodBodyImpl response, List<Member> members) { _response = response; _members = members; } - public void response(List<AMQMethodBody> responses, List<Member> members) + public void response(List<AMQMethodBodyImpl> responses, List<Member> members) { - for (AMQMethodBody r : responses) + for (AMQMethodBodyImpl r : responses) { assertEquals(_response, r); } diff --git a/java/cluster/src/test/java/org/apache/qpid/server/cluster/TestBroker.java b/java/cluster/src/test/java/org/apache/qpid/server/cluster/TestBroker.java index d3ccbf0ac6..7f513530e0 100644 --- a/java/cluster/src/test/java/org/apache/qpid/server/cluster/TestBroker.java +++ b/java/cluster/src/test/java/org/apache/qpid/server/cluster/TestBroker.java @@ -23,7 +23,7 @@ package org.apache.qpid.server.cluster; import org.apache.qpid.AMQException; import org.apache.qpid.framing.AMQDataBlock; import org.apache.qpid.framing.AMQFrame; -import org.apache.qpid.framing.AMQMethodBody; +import org.apache.qpid.framing.AMQMethodBodyImpl; import java.io.IOException; @@ -39,16 +39,16 @@ class TestBroker extends Broker return true; } - void connectAsynch(Iterable<AMQMethodBody> msgs) + void connectAsynch(Iterable<AMQMethodBodyImpl> msgs) { replay(msgs); } - void replay(Iterable<AMQMethodBody> msgs) + void replay(Iterable<AMQMethodBodyImpl> msgs) { try { - for (AMQMethodBody b : msgs) + for (AMQMethodBodyImpl b : msgs) { send(new AMQFrame(0, b)); } diff --git a/java/cluster/src/test/java/org/apache/qpid/server/cluster/TestReplayManager.java b/java/cluster/src/test/java/org/apache/qpid/server/cluster/TestReplayManager.java index c529c83cc0..ba62e86101 100644 --- a/java/cluster/src/test/java/org/apache/qpid/server/cluster/TestReplayManager.java +++ b/java/cluster/src/test/java/org/apache/qpid/server/cluster/TestReplayManager.java @@ -20,7 +20,7 @@ */ package org.apache.qpid.server.cluster; -import org.apache.qpid.framing.AMQMethodBody; +import org.apache.qpid.framing.AMQMethodBodyImpl; import org.apache.qpid.server.cluster.replay.ReplayManager; import java.util.ArrayList; @@ -28,19 +28,19 @@ import java.util.List; class TestReplayManager implements ReplayManager { - private final List<AMQMethodBody> _msgs; + private final List<AMQMethodBodyImpl> _msgs; TestReplayManager() { - this(new ArrayList<AMQMethodBody>()); + this(new ArrayList<AMQMethodBodyImpl>()); } - TestReplayManager(List<AMQMethodBody> msgs) + TestReplayManager(List<AMQMethodBodyImpl> msgs) { _msgs = msgs; } - public List<AMQMethodBody> replay(boolean isLeader) + public List<AMQMethodBodyImpl> replay(boolean isLeader) { return _msgs; } |