diff options
| author | Robert Godfrey <rgodfrey@apache.org> | 2014-01-22 21:43:46 +0000 |
|---|---|---|
| committer | Robert Godfrey <rgodfrey@apache.org> | 2014-01-22 21:43:46 +0000 |
| commit | 04560e1d3c28fb21a8f8ae094a62318790474e61 (patch) | |
| tree | 32bef19f14c57e5722f29b3338a40b5dce145aba /qpid/java/systests/src | |
| parent | 8a8da44b127644ac9cfb43eef88d3f31a35f9aca (diff) | |
| download | qpid-python-04560e1d3c28fb21a8f8ae094a62318790474e61.tar.gz | |
QPID-5504 : remove InboundMessage... characterize routing as being on the immutable message and a set of instance properties
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1560524 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/systests/src')
| -rw-r--r-- | qpid/java/systests/src/main/java/org/apache/qpid/server/store/MessageStoreTest.java | 3 |
1 files changed, 2 insertions, 1 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 19dc1a5a02..861b225e6f 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 @@ -40,6 +40,7 @@ import org.apache.qpid.server.configuration.VirtualHostConfiguration; import org.apache.qpid.server.exchange.DirectExchange; import org.apache.qpid.server.exchange.Exchange; import org.apache.qpid.server.exchange.TopicExchange; +import org.apache.qpid.server.message.InstanceProperties; import org.apache.qpid.server.model.Queue; import org.apache.qpid.server.protocol.v0_8.AMQMessage; import org.apache.qpid.server.protocol.v0_8.MessageMetaData; @@ -623,7 +624,7 @@ public class MessageStoreTest extends QpidTestCase storedMessage.flushToStore(); final AMQMessage currentMessage = new AMQMessage(storedMessage); - final List<? extends BaseQueue> destinationQueues = exchange.route(currentMessage); + final List<? extends BaseQueue> destinationQueues = exchange.route(currentMessage, InstanceProperties.EMPTY); ServerTransaction trans = new AutoCommitTransaction(getVirtualHost().getMessageStore()); |