From c2e8c9c9318334f1fd3073abab8a0a764552cbd3 Mon Sep 17 00:00:00 2001 From: Robert Greig Date: Sun, 7 Jan 2007 23:11:53 +0000 Subject: QPID-32: new model for holding and processing message in memory to support new persistent stores git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@493872 13f79535-47bb-0310-9956-ffa450edef68 --- .../test/java/org/apache/qpid/server/cluster/BrokerTest.java | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) (limited to 'qpid/java/cluster/src/test') diff --git a/qpid/java/cluster/src/test/java/org/apache/qpid/server/cluster/BrokerTest.java b/qpid/java/cluster/src/test/java/org/apache/qpid/server/cluster/BrokerTest.java index ed18710c64..20e092bde7 100644 --- a/qpid/java/cluster/src/test/java/org/apache/qpid/server/cluster/BrokerTest.java +++ b/qpid/java/cluster/src/test/java/org/apache/qpid/server/cluster/BrokerTest.java @@ -45,7 +45,7 @@ public class BrokerTest extends TestCase new RecordingBroker("C", 3) }; GroupResponseValidator handler = new GroupResponseValidator(new TestMethod("response"), new ArrayList(Arrays.asList(brokers))); - GroupRequest grpRequest = new GroupRequest(new SimpleSendable(new TestMethod("request")), StandardPolicies.SYNCH_POLICY, handler); + GroupRequest grpRequest = new GroupRequest(new SimpleBodySendable(new TestMethod("request")), StandardPolicies.SYNCH_POLICY, handler); for (Broker b : brokers) { b.invoke(grpRequest); @@ -70,7 +70,7 @@ public class BrokerTest extends TestCase RecordingBroker[] succeeded = new RecordingBroker[]{a, c}; GroupResponseValidator handler = new GroupResponseValidator(new TestMethod("response"), new ArrayList(Arrays.asList(succeeded))); - GroupRequest grpRequest = new GroupRequest(new SimpleSendable(new TestMethod("request")), StandardPolicies.SYNCH_POLICY, handler); + GroupRequest grpRequest = new GroupRequest(new SimpleBodySendable(new TestMethod("request")), StandardPolicies.SYNCH_POLICY, handler); for (Broker broker : all) { @@ -99,7 +99,7 @@ public class BrokerTest extends TestCase RecordingBroker broker = new RecordingBroker("myhost", 1); for (AMQBody msg : msgs) { - broker.send(new SimpleSendable(msg), null); + broker.send(new SimpleBodySendable(msg), null); } List sent = broker.getMessages(); assertEquals(msgs.length, sent.size()); @@ -115,7 +115,7 @@ public class BrokerTest extends TestCase { RecordingBroker broker = new RecordingBroker("myhost", 1); BlockingHandler handler = new BlockingHandler(); - broker.send(new SimpleSendable(new TestMethod("A")), handler); + broker.send(new SimpleBodySendable(new TestMethod("A")), handler); List sent = broker.getMessages(); assertEquals(1, sent.size()); assertTrue(sent.get(0) instanceof AMQFrame); @@ -131,7 +131,7 @@ public class BrokerTest extends TestCase { RecordingBroker broker = new RecordingBroker("myhost", 1); BlockingHandler handler = new BlockingHandler(); - broker.send(new SimpleSendable(new TestMethod("A")), handler); + broker.send(new SimpleBodySendable(new TestMethod("A")), handler); List sent = broker.getMessages(); assertEquals(1, sent.size()); assertTrue(sent.get(0) instanceof AMQFrame); -- cgit v1.2.1