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

1 files changed, 1 insertions, 23 deletions

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<? extends BaseQueue> 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);
 
     }