diff options
author | Robert Godfrey <rgodfrey@apache.org> | 2014-09-30 15:30:43 +0000 |
---|---|---|
committer | Robert Godfrey <rgodfrey@apache.org> | 2014-09-30 15:30:43 +0000 |
commit | 907a77ca345ae585038d502a059f9e0a42d1d50c (patch) | |
tree | 6a205097a89c60fe4daaba0c8ec1a5545220f800 /java/systests/src/test/java/org/apache/qpid/server/store/VirtualHostMessageStoreTest.java | |
parent | 65bd98e140d6a186721219cd2b94c6be82ef0dba (diff) | |
download | qpid-python-907a77ca345ae585038d502a059f9e0a42d1d50c.tar.gz |
Remove handlers
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6125-ProtocolRefactoring@1628473 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/systests/src/test/java/org/apache/qpid/server/store/VirtualHostMessageStoreTest.java')
-rw-r--r-- | java/systests/src/test/java/org/apache/qpid/server/store/VirtualHostMessageStoreTest.java | 50 |
1 files changed, 1 insertions, 49 deletions
diff --git a/java/systests/src/test/java/org/apache/qpid/server/store/VirtualHostMessageStoreTest.java b/java/systests/src/test/java/org/apache/qpid/server/store/VirtualHostMessageStoreTest.java index 9626bb017f..ec17f224c1 100644 --- a/java/systests/src/test/java/org/apache/qpid/server/store/VirtualHostMessageStoreTest.java +++ b/java/systests/src/test/java/org/apache/qpid/server/store/VirtualHostMessageStoreTest.java @@ -597,7 +597,7 @@ public class VirtualHostMessageStoreTest extends QpidTestCase headers.setString("Test", "MST"); properties.setHeaders(headers); - MessagePublishInfo messageInfo = new TestMessagePublishInfo(exchange, false, false, routingKey); + MessagePublishInfo messageInfo = new MessagePublishInfo(new AMQShortString(exchange.getName()), false, false, new AMQShortString(routingKey)); ContentHeaderBody headerBody = new ContentHeaderBody(BasicConsumeBody.CLASS_ID,0,properties,0l); @@ -824,52 +824,4 @@ public class VirtualHostMessageStoreTest extends QpidTestCase assertEquals("Incorrect Message count on queue:" + queueName, messageCount, queue.getQueueDepthMessages()); } - - private class TestMessagePublishInfo implements MessagePublishInfo - { - - ExchangeImpl<?> _exchange; - boolean _immediate; - boolean _mandatory; - String _routingKey; - - TestMessagePublishInfo(ExchangeImpl<?> exchange, boolean immediate, boolean mandatory, String routingKey) - { - _exchange = exchange; - _immediate = immediate; - _mandatory = mandatory; - _routingKey = routingKey; - } - - @Override - public AMQShortString getExchange() - { - return new AMQShortString(_exchange.getName()); - } - - @Override - public void setExchange(AMQShortString exchange) - { - //no-op - } - - @Override - public boolean isImmediate() - { - return _immediate; - } - - @Override - public boolean isMandatory() - { - return _mandatory; - } - - @Override - public AMQShortString getRoutingKey() - { - return new AMQShortString(_routingKey); - } - } - } |