org.apache.qpid.server.subscription
Class SubscriptionFactoryImpl

java.lang.Object
  extended by org.apache.qpid.server.subscription.SubscriptionFactoryImpl
All Implemented Interfaces:
SubscriptionFactory

public class SubscriptionFactoryImpl
extends Object
implements SubscriptionFactory


Field Summary
static SubscriptionFactoryImpl INSTANCE
           
 
Constructor Summary
SubscriptionFactoryImpl()
           
 
Method Summary
 Subscription createSubscription(AMQChannel channel, AMQProtocolSession protocolSession, org.apache.qpid.framing.AMQShortString consumerTag, boolean acks, org.apache.qpid.framing.FieldTable filters, boolean noLocal, FlowCreditManager creditManager, ClientDeliveryMethod clientMethod, RecordDeliveryMethod recordMethod)
           
 Subscription createSubscription(int channelId, AMQProtocolSession protocolSession, org.apache.qpid.framing.AMQShortString consumerTag, boolean acks, org.apache.qpid.framing.FieldTable filters, boolean noLocal, FlowCreditManager creditManager)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

INSTANCE

public static final SubscriptionFactoryImpl INSTANCE
Constructor Detail

SubscriptionFactoryImpl

public SubscriptionFactoryImpl()
Method Detail

createSubscription

public Subscription createSubscription(int channelId,
                                       AMQProtocolSession protocolSession,
                                       org.apache.qpid.framing.AMQShortString consumerTag,
                                       boolean acks,
                                       org.apache.qpid.framing.FieldTable filters,
                                       boolean noLocal,
                                       FlowCreditManager creditManager)
                                throws org.apache.qpid.AMQException
Specified by:
createSubscription in interface SubscriptionFactory
Throws:
org.apache.qpid.AMQException

createSubscription

public Subscription createSubscription(AMQChannel channel,
                                       AMQProtocolSession protocolSession,
                                       org.apache.qpid.framing.AMQShortString consumerTag,
                                       boolean acks,
                                       org.apache.qpid.framing.FieldTable filters,
                                       boolean noLocal,
                                       FlowCreditManager creditManager,
                                       ClientDeliveryMethod clientMethod,
                                       RecordDeliveryMethod recordMethod)
                                throws org.apache.qpid.AMQException
Specified by:
createSubscription in interface SubscriptionFactory
Throws:
org.apache.qpid.AMQException


Licensed to the Apache Software Foundation