From 6823d23dbeca328f4e860538a52015bc9313a6db Mon Sep 17 00:00:00 2001 From: Robert Godfrey Date: Sat, 1 Feb 2014 15:40:47 +0000 Subject: QPID-5504 : Moving routing to Exchange from session classes git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1563431 13f79535-47bb-0310-9956-ffa450edef68 --- .../apache/qpid/server/store/MessageStoreTest.java | 24 +--------------------- 1 file changed, 1 insertion(+), 23 deletions(-) (limited to 'qpid/java/systests/src') diff --git a/qpid/java/systests/src/main/java/org/apache/qpid/server/store/MessageStoreTest.java b/qpid/java/systests/src/main/java/org/apache/qpid/server/store/MessageStoreTest.java index 861b225e6f..f92a133919 100644 --- a/qpid/java/systests/src/main/java/org/apache/qpid/server/store/MessageStoreTest.java +++ b/qpid/java/systests/src/main/java/org/apache/qpid/server/store/MessageStoreTest.java @@ -624,32 +624,10 @@ public class MessageStoreTest extends QpidTestCase storedMessage.flushToStore(); final AMQMessage currentMessage = new AMQMessage(storedMessage); - final List destinationQueues = exchange.route(currentMessage, InstanceProperties.EMPTY); ServerTransaction trans = new AutoCommitTransaction(getVirtualHost().getMessageStore()); - - trans.enqueue(destinationQueues, currentMessage, new ServerTransaction.Action() { - public void postCommit() - { - try - { - for(BaseQueue queue : destinationQueues) - { - queue.enqueue(currentMessage); - } - } - catch (AMQException e) - { - _logger.error("Problem enqueing message", e); - } - } - - public void onRollback() - { - //To change body of implemented methods use File | Settings | File Templates. - } - }); + exchange.send(currentMessage, InstanceProperties.EMPTY, trans, null); } -- cgit v1.2.1