1 files changed, 16 insertions, 4 deletions
diff --git a/java/broker-core/src/test/java/org/apache/qpid/server/queue/MockAMQQueue.java b/java/broker-core/src/test/java/org/apache/qpid/server/queue/MockAMQQueue.java
index 98ecdcdd3b..e8b644045a 100644
--- a/java/broker-core/src/test/java/org/apache/qpid/server/queue/MockAMQQueue.java
+++ b/java/broker-core/src/test/java/org/apache/qpid/server/queue/MockAMQQueue.java
@@ -24,16 +24,20 @@ import org.apache.qpid.AMQException;
 import org.apache.qpid.server.binding.Binding;
 import org.apache.qpid.server.configuration.QueueConfiguration;
 import org.apache.qpid.server.exchange.Exchange;
+import org.apache.qpid.server.filter.FilterManager;
 import org.apache.qpid.server.logging.LogSubject;
 import org.apache.qpid.server.message.ServerMessage;
 import org.apache.qpid.server.protocol.AMQSessionModel;
 import org.apache.qpid.server.security.AuthorizationHolder;
+import org.apache.qpid.server.subscription.DelegatingSubscription;
 import org.apache.qpid.server.subscription.Subscription;
+import org.apache.qpid.server.subscription.SubscriptionTarget;
 import org.apache.qpid.server.util.Action;
 import org.apache.qpid.server.virtualhost.VirtualHost;
 
 import java.util.Collection;
 import java.util.Collections;
+import java.util.EnumSet;
 import java.util.List;
 import java.util.Set;
 import java.util.UUID;
@@ -203,16 +207,24 @@ public class MockAMQQueue implements AMQQueue
         return _virtualhost;
     }
 
-    public String getName()
+    @Override
+    public Subscription registerSubscription(final SubscriptionTarget target,
+                                             final FilterManager filters,
+                                             final Class<? extends ServerMessage> messageClass,
+                                             final String consumerName,
+                                             final EnumSet<Subscription.Option> options) throws AMQException
     {
-        return _name;
+        return new DelegatingSubscription(filters, messageClass, options.contains(Subscription.Option.ACQUIRES),
+                                          options.contains(Subscription.Option.SEES_REQUEUES), consumerName,
+                                          options.contains(Subscription.Option.TRANSIENT), target );
     }
 
-    public void registerSubscription(Subscription subscription, boolean exclusive) throws AMQException
+    public String getName()
     {
-
+        return _name;
     }
 
+
     public void unregisterSubscription(Subscription subscription) throws AMQException
     {