From 500491f93c105e109f5933b5d33a12b45bc4b272 Mon Sep 17 00:00:00 2001 From: Robert Godfrey Date: Mon, 17 Feb 2014 20:48:05 +0000 Subject: QPID-5555 : [Java Broker] Modify implementation of Queues to provide better notions of exclusivity and lifetime git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1569109 13f79535-47bb-0310-9956-ffa450edef68 --- .../apache/qpid/server/store/berkeleydb/upgrade/UpgradeFrom5To6.java | 2 +- .../qpid/server/store/berkeleydb/upgrade/UpgradeFrom5To6Test.java | 1 + 2 files changed, 2 insertions(+), 1 deletion(-) (limited to 'qpid/java/bdbstore/src') diff --git a/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/upgrade/UpgradeFrom5To6.java b/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/upgrade/UpgradeFrom5To6.java index 9b1ab7057b..46f2afd741 100644 --- a/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/upgrade/UpgradeFrom5To6.java +++ b/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/upgrade/UpgradeFrom5To6.java @@ -568,7 +568,7 @@ public class UpgradeFrom5To6 extends AbstractStoreUpgrade Map attributesMap = new HashMap(); attributesMap.put(Exchange.NAME, exchangeName); attributesMap.put(Exchange.TYPE, exchangeType); - attributesMap.put(Exchange.LIFETIME_POLICY, autoDelete ? LifetimePolicy.AUTO_DELETE.name() + attributesMap.put(Exchange.LIFETIME_POLICY, autoDelete ? "AUTO_DELETE" : LifetimePolicy.PERMANENT.name()); String json = _serializer.serialize(attributesMap); UpgradeConfiguredObjectRecord configuredObject = new UpgradeConfiguredObjectRecord(Exchange.class.getName(), json); diff --git a/qpid/java/bdbstore/src/test/java/org/apache/qpid/server/store/berkeleydb/upgrade/UpgradeFrom5To6Test.java b/qpid/java/bdbstore/src/test/java/org/apache/qpid/server/store/berkeleydb/upgrade/UpgradeFrom5To6Test.java index 44f0861275..02494009c1 100644 --- a/qpid/java/bdbstore/src/test/java/org/apache/qpid/server/store/berkeleydb/upgrade/UpgradeFrom5To6Test.java +++ b/qpid/java/bdbstore/src/test/java/org/apache/qpid/server/store/berkeleydb/upgrade/UpgradeFrom5To6Test.java @@ -44,6 +44,7 @@ import java.util.UUID; import org.apache.log4j.Logger; import org.apache.qpid.server.model.Binding; import org.apache.qpid.server.model.Exchange; +import org.apache.qpid.server.model.ExclusivityPolicy; import org.apache.qpid.server.model.LifetimePolicy; import org.apache.qpid.server.model.Queue; import org.apache.qpid.server.model.UUIDGenerator; -- cgit v1.2.1