diff options
Diffstat (limited to 'java/broker/src/main/java/org/apache/qpid/server/subscription/SubscriptionFactory.java')
| -rw-r--r-- | java/broker/src/main/java/org/apache/qpid/server/subscription/SubscriptionFactory.java | 12 |
1 files changed, 12 insertions, 0 deletions
diff --git a/java/broker/src/main/java/org/apache/qpid/server/subscription/SubscriptionFactory.java b/java/broker/src/main/java/org/apache/qpid/server/subscription/SubscriptionFactory.java index 3e6db071e3..ce0362d73f 100644 --- a/java/broker/src/main/java/org/apache/qpid/server/subscription/SubscriptionFactory.java +++ b/java/broker/src/main/java/org/apache/qpid/server/subscription/SubscriptionFactory.java @@ -26,6 +26,7 @@ import org.apache.qpid.framing.FieldTable; import org.apache.qpid.server.protocol.AMQProtocolSession; import org.apache.qpid.server.flow.FlowCreditManager; import org.apache.qpid.server.subscription.Subscription; +import org.apache.qpid.server.AMQChannel; /** * Allows the customisation of the creation of a subscription. This is typically done within an AMQQueue. This factory @@ -44,4 +45,15 @@ public interface SubscriptionFactory boolean noLocal, FlowCreditManager creditManager) throws AMQException; + Subscription createSubscription(AMQChannel channel, + AMQProtocolSession protocolSession, + AMQShortString consumerTag, + boolean acks, + FieldTable filters, + boolean noLocal, + FlowCreditManager creditManager, + ClientDeliveryMethod clientMethod, + RecordDeliveryMethod recordMethod + ) + throws AMQException; } |