From 3fb9be28593263e12623ce09084a230b59b81f4f Mon Sep 17 00:00:00 2001
From: Robert Godfrey <rgodfrey@apache.org>
Date: Thu, 22 Mar 2007 13:14:42 +0000
Subject: made a copy

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/java.multi_version@521253 13f79535-47bb-0310-9956-ffa450edef68
---
 .../org/apache/qpid/server/cluster/BrokerTest.java     | 18 +++++++++---------
 .../org/apache/qpid/server/cluster/TestBroker.java     |  8 ++++----
 .../apache/qpid/server/cluster/TestReplayManager.java  | 10 +++++-----
 3 files changed, 18 insertions(+), 18 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 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;
     }
-- 
cgit v1.2.1