summaryrefslogtreecommitdiff
path: root/java/systests/src/test/java/org/apache/qpid/server/store/VirtualHostMessageStoreTest.java
diff options
context:
space:
mode:
authorRobert Godfrey <rgodfrey@apache.org>2014-09-30 15:30:43 +0000
committerRobert Godfrey <rgodfrey@apache.org>2014-09-30 15:30:43 +0000
commit907a77ca345ae585038d502a059f9e0a42d1d50c (patch)
tree6a205097a89c60fe4daaba0c8ec1a5545220f800 /java/systests/src/test/java/org/apache/qpid/server/store/VirtualHostMessageStoreTest.java
parent65bd98e140d6a186721219cd2b94c6be82ef0dba (diff)
downloadqpid-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.java50
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);
- }
- }
-
}