From 4cc3b71403b86b29466b658e0fae715c2f9c8535 Mon Sep 17 00:00:00 2001 From: Martin Ritchie Date: Mon, 9 Feb 2009 13:46:00 +0000 Subject: QPID-1652 : Created MessagePublishInfoImpl and Unit Test, removed the several annoynmous classes that did all the same work. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@742496 13f79535-47bb-0310-9956-ffa450edef68 --- .../qpid/server/store/DerbyMessageStore.java | 30 ++-------------------- 1 file changed, 2 insertions(+), 28 deletions(-) (limited to 'java/broker/src/main') diff --git a/java/broker/src/main/java/org/apache/qpid/server/store/DerbyMessageStore.java b/java/broker/src/main/java/org/apache/qpid/server/store/DerbyMessageStore.java index 743a736884..f23983641b 100644 --- a/java/broker/src/main/java/org/apache/qpid/server/store/DerbyMessageStore.java +++ b/java/broker/src/main/java/org/apache/qpid/server/store/DerbyMessageStore.java @@ -29,6 +29,7 @@ import org.apache.qpid.server.queue.QueueRegistry; import org.apache.qpid.server.queue.AMQMessage; import org.apache.qpid.server.queue.MessageHandleFactory; +import org.apache.qpid.framing.abstraction.MessagePublishInfoImpl; import org.apache.qpid.server.txn.TransactionalContext; import org.apache.qpid.server.txn.NonTransactionalContext; import org.apache.qpid.AMQException; @@ -1148,34 +1149,7 @@ public class DerbyMessageStore implements MessageStore final AMQShortString routingKey = rs.getString(2) == null ? null : new AMQShortString(rs.getString(2)); final boolean mandatory = (rs.getShort(3) != (short)0); final boolean immediate = (rs.getShort(4) != (short)0); - MessagePublishInfo info = new MessagePublishInfo() - { - - public AMQShortString getExchange() - { - return exchange; - } - - public void setExchange(AMQShortString exchange) - { - - } - - public boolean isImmediate() - { - return immediate; - } - - public boolean isMandatory() - { - return mandatory; - } - - public AMQShortString getRoutingKey() - { - return routingKey; - } - } ; + MessagePublishInfo info = new MessagePublishInfoImpl(exchange,immediate,mandatory,routingKey); Blob dataAsBlob = rs.getBlob(5); -- cgit v1.2.1