From 3203eea7641e1b0f39de96d797db7c54423b7f02 Mon Sep 17 00:00:00 2001 From: Robert Gemmell Date: Tue, 17 Apr 2012 09:01:44 +0000 Subject: QPID-3923: Store queue, exchange and binding as configured objects in bdb store Applied patch by Oleksandr Rudyy , Phil Harvey , and myself. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1327003 13f79535-47bb-0310-9956-ffa450edef68 --- .../main/java/org/apache/qpid/server/store/SlowMessageStore.java | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) (limited to 'qpid/java/systests/src/main') diff --git a/qpid/java/systests/src/main/java/org/apache/qpid/server/store/SlowMessageStore.java b/qpid/java/systests/src/main/java/org/apache/qpid/server/store/SlowMessageStore.java index 69cc64c0d0..f2d4a513be 100644 --- a/qpid/java/systests/src/main/java/org/apache/qpid/server/store/SlowMessageStore.java +++ b/qpid/java/systests/src/main/java/org/apache/qpid/server/store/SlowMessageStore.java @@ -26,6 +26,7 @@ import org.apache.log4j.Logger; import org.apache.qpid.AMQStoreException; import org.apache.qpid.framing.AMQShortString; import org.apache.qpid.framing.FieldTable; +import org.apache.qpid.server.binding.Binding; import org.apache.qpid.server.exchange.Exchange; import org.apache.qpid.server.federation.Bridge; import org.apache.qpid.server.federation.BrokerLink; @@ -191,17 +192,17 @@ public class SlowMessageStore implements MessageStore doPostDelay("removeExchange"); } - public void bindQueue(Exchange exchange, AMQShortString routingKey, AMQQueue queue, FieldTable args) throws AMQStoreException + public void bindQueue(Binding binding) throws AMQStoreException { doPreDelay("bindQueue"); - _durableConfigurationStore.bindQueue(exchange, routingKey, queue, args); + _durableConfigurationStore.bindQueue(binding); doPostDelay("bindQueue"); } - public void unbindQueue(Exchange exchange, AMQShortString routingKey, AMQQueue queue, FieldTable args) throws AMQStoreException + public void unbindQueue(Binding binding) throws AMQStoreException { doPreDelay("unbindQueue"); - _durableConfigurationStore.unbindQueue(exchange, routingKey, queue, args); + _durableConfigurationStore.unbindQueue(binding); doPostDelay("unbindQueue"); } -- cgit v1.2.1