From c53cf3df85bb5a37ec7ec000667cba4012c35e85 Mon Sep 17 00:00:00 2001 From: Martin Ritchie Date: Thu, 7 Aug 2008 15:37:36 +0000 Subject: QPID-1195 , QPID-1193 Initial changes to allow bind and queue arguments to be stored and recovered from the MessageStore. Created a test to validate that the stored values can be recovered. DerbyStore hasn't fully been implemented. Surrounding work has been done and tested with BDBMessageStore. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@683632 13f79535-47bb-0310-9956-ffa450edef68 --- .../java/org/apache/qpid/server/store/SkeletonMessageStore.java | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) (limited to 'java/systests/src') diff --git a/java/systests/src/main/java/org/apache/qpid/server/store/SkeletonMessageStore.java b/java/systests/src/main/java/org/apache/qpid/server/store/SkeletonMessageStore.java index 792744903e..e2be503926 100644 --- a/java/systests/src/main/java/org/apache/qpid/server/store/SkeletonMessageStore.java +++ b/java/systests/src/main/java/org/apache/qpid/server/store/SkeletonMessageStore.java @@ -78,7 +78,7 @@ public class SkeletonMessageStore implements MessageStore //To change body of implemented methods use File | Settings | File Templates. } - public void createQueue(AMQQueue queue) throws AMQException + public void createQueue(AMQQueue queue, FieldTable arguments) throws AMQException { } @@ -129,6 +129,11 @@ public class SkeletonMessageStore implements MessageStore return null; } + public boolean isPersistent() + { + return false; + } + public void removeQueue(final AMQQueue queue) throws AMQException { -- cgit v1.2.1