diff options
Diffstat (limited to 'qpid/java/broker/src/main/java/org/apache/qpid/server/virtualhost/AbstractVirtualHost.java')
| -rw-r--r-- | qpid/java/broker/src/main/java/org/apache/qpid/server/virtualhost/AbstractVirtualHost.java | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/qpid/java/broker/src/main/java/org/apache/qpid/server/virtualhost/AbstractVirtualHost.java b/qpid/java/broker/src/main/java/org/apache/qpid/server/virtualhost/AbstractVirtualHost.java index a704ca112b..e89fa8b545 100644 --- a/qpid/java/broker/src/main/java/org/apache/qpid/server/virtualhost/AbstractVirtualHost.java +++ b/qpid/java/broker/src/main/java/org/apache/qpid/server/virtualhost/AbstractVirtualHost.java @@ -56,6 +56,7 @@ import org.apache.qpid.server.queue.QueueRegistry; import org.apache.qpid.server.security.SecurityManager; import org.apache.qpid.server.stats.StatisticsCounter; import org.apache.qpid.server.stats.StatisticsGatherer; +import org.apache.qpid.server.store.DurableConfigurationStoreHelper; import org.apache.qpid.server.store.Event; import org.apache.qpid.server.store.EventListener; import org.apache.qpid.server.txn.DtxRegistry; @@ -294,7 +295,7 @@ public abstract class AbstractVirtualHost implements VirtualHost, IConnectionReg if (newExchange.isDurable()) { - getDurableConfigurationStore().createExchange(newExchange); + DurableConfigurationStoreHelper.createExchange(getDurableConfigurationStore(), newExchange); } } } @@ -306,7 +307,7 @@ public abstract class AbstractVirtualHost implements VirtualHost, IConnectionReg if (queue.isDurable()) { - getDurableConfigurationStore().createQueue(queue); + DurableConfigurationStoreHelper.createQueue(getDurableConfigurationStore(), queue, null); } //get the exchange name (returns default exchange name if none was specified) |