From dcb385632204f07536374d660ed9232b7a18052b Mon Sep 17 00:00:00 2001 From: Alex Rudyy Date: Wed, 29 Oct 2014 15:56:47 +0000 Subject: QPID-5650: Move attribute names into upgrader constants git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1635183 13f79535-47bb-0310-9956-ffa450edef68 --- .../qpid/server/store/VirtualHostStoreUpgraderAndRecoverer.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) (limited to 'qpid/java') diff --git a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/store/VirtualHostStoreUpgraderAndRecoverer.java b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/store/VirtualHostStoreUpgraderAndRecoverer.java index 313e8d1d0c..cd3ae5fdb7 100644 --- a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/store/VirtualHostStoreUpgraderAndRecoverer.java +++ b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/store/VirtualHostStoreUpgraderAndRecoverer.java @@ -38,8 +38,6 @@ import org.apache.qpid.server.model.UUIDGenerator; import org.apache.qpid.server.model.VirtualHost; import org.apache.qpid.server.model.VirtualHostNode; import org.apache.qpid.server.queue.QueueArgumentsConverter; -import org.apache.qpid.server.virtualhost.AbstractVirtualHost; -import org.apache.qpid.server.virtualhost.VirtualHostImpl; public class VirtualHostStoreUpgraderAndRecoverer { @@ -351,6 +349,8 @@ public class VirtualHostStoreUpgraderAndRecoverer private class Upgrader_0_4_to_2_0 extends StoreUpgraderPhase { private static final String ALTERNATE_EXCHANGE = "alternateExchange"; + private static final String DLQ_ENABLED_ARGUMENT = "x-qpid-dlq-enabled"; + private static final String DEFAULT_DLE_NAME_SUFFIX = "_DLE"; private Map _missingAmqpExchanges = new HashMap(DEFAULT_EXCHANGES); private ConfiguredObjectRecord _virtualHostRecord; @@ -430,7 +430,7 @@ public class VirtualHostStoreUpgraderAndRecoverer private ConfiguredObjectRecord updateQueueRecordIfNecessary(ConfiguredObjectRecord record) { Map attributes = record.getAttributes(); - boolean queueDLQEnabled = Boolean.parseBoolean(String.valueOf(attributes.get(AbstractVirtualHost.CREATE_DLQ_ON_CREATION))); + boolean queueDLQEnabled = Boolean.parseBoolean(String.valueOf(attributes.get(DLQ_ENABLED_ARGUMENT))); if(queueDLQEnabled && attributes.get(ALTERNATE_EXCHANGE) == null) { Object queueName = attributes.get("name"); @@ -439,7 +439,7 @@ public class VirtualHostStoreUpgraderAndRecoverer throw new IllegalConfigurationException("Queue name is not found in queue configuration entry attributes: " + attributes); } - String dleSuffix = System.getProperty(BrokerProperties.PROPERTY_DEAD_LETTER_EXCHANGE_SUFFIX, VirtualHostImpl.DEFAULT_DLE_NAME_SUFFIX); + String dleSuffix = System.getProperty(BrokerProperties.PROPERTY_DEAD_LETTER_EXCHANGE_SUFFIX, DEFAULT_DLE_NAME_SUFFIX); String dleExchangeName = queueName + dleSuffix; ConfiguredObjectRecord exchangeRecord = findConfiguredObjectRecordInUpdateMap("Exchange", dleExchangeName); -- cgit v1.2.1