|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Uses of Subscription in org.apache.qpid.server |
---|
Fields in org.apache.qpid.server with type parameters of type Subscription | |
---|---|
protected Map<org.apache.qpid.framing.AMQShortString,Subscription> |
AMQChannel._tag2SubscriptionMap
Maps from consumer tag to subscription instance. |
Methods in org.apache.qpid.server that return Subscription | |
---|---|
Subscription |
AMQChannel.getSubscription(org.apache.qpid.framing.AMQShortString subscription)
|
Methods in org.apache.qpid.server with parameters of type Subscription | |
---|---|
void |
AMQChannel.addUnacknowledgedMessage(QueueEntry entry,
long deliveryTag,
Subscription subscription)
Add a message to the channel-based list of unacknowledged messages |
Uses of Subscription in org.apache.qpid.server.handler |
---|
Classes in org.apache.qpid.server.handler that implement Subscription | |
---|---|
static class |
BasicGetMethodHandler.GetNoAckSubscription
|
Uses of Subscription in org.apache.qpid.server.logging.actors |
---|
Constructors in org.apache.qpid.server.logging.actors with parameters of type Subscription | |
---|---|
SubscriptionActor(RootMessageLogger logger,
Subscription subscription)
|
Uses of Subscription in org.apache.qpid.server.logging.subjects |
---|
Constructors in org.apache.qpid.server.logging.subjects with parameters of type Subscription | |
---|---|
SubscriptionLogSubject(Subscription subscription)
Create an QueueLogSubject that Logs in the following format. |
Uses of Subscription in org.apache.qpid.server.queue |
---|
Methods in org.apache.qpid.server.queue that return Subscription | |
---|---|
Subscription |
QueueEntry.getDeliveredSubscription()
|
Subscription |
QueueEntryImpl.getDeliveredSubscription()
|
Subscription |
QueueEntry.SubscriptionAcquiredState.getSubscription()
|
Subscription |
QueueEntry.SubscriptionAssignedState.getSubscription()
|
Methods in org.apache.qpid.server.queue with parameters of type Subscription | |
---|---|
boolean |
QueueEntry.acquire(Subscription sub)
|
boolean |
QueueEntryImpl.acquire(Subscription sub)
|
void |
AMQQueue.deliverAsync(Subscription sub)
|
void |
SimpleAMQQueue.deliverAsync(Subscription sub)
|
void |
AMQQueue.dequeue(QueueEntry entry,
Subscription sub)
|
void |
SimpleAMQQueue.dequeue(QueueEntry entry,
Subscription sub)
|
void |
AMQQueue.flushSubscription(Subscription sub)
|
void |
SimpleAMQQueue.flushSubscription(Subscription sub)
|
boolean |
SimpleAMQQueue.flushSubscription(Subscription sub,
long iterations)
|
boolean |
QueueEntry.isAcquiredBy(Subscription subscription)
|
boolean |
QueueEntryImpl.isAcquiredBy(Subscription subscription)
|
boolean |
QueueEntry.isRejectedBy(Subscription subscription)
|
boolean |
QueueEntryImpl.isRejectedBy(Subscription subscription)
|
void |
AMQQueue.registerSubscription(Subscription subscription,
boolean exclusive)
|
void |
SimpleAMQQueue.registerSubscription(Subscription subscription,
boolean exclusive)
|
void |
QueueEntry.reject(Subscription subscription)
|
void |
QueueEntryImpl.reject(Subscription subscription)
|
void |
AMQQueue.requeue(QueueEntryImpl storeContext,
Subscription subscription)
|
void |
SimpleAMQQueue.requeue(QueueEntryImpl entry,
Subscription subscription)
|
void |
QueueEntry.requeue(Subscription subscription)
|
void |
QueueEntryImpl.requeue(Subscription subscription)
|
boolean |
AMQQueue.resend(QueueEntry entry,
Subscription subscription)
|
boolean |
SimpleAMQQueue.resend(QueueEntry entry,
Subscription subscription)
|
void |
SimpleAMQQueue.stateChange(Subscription sub,
Subscription.State oldState,
Subscription.State newState)
|
void |
AMQQueue.unregisterSubscription(Subscription subscription)
|
void |
SimpleAMQQueue.unregisterSubscription(Subscription subscription)
|
Constructors in org.apache.qpid.server.queue with parameters of type Subscription | |
---|---|
QueueEntry.SubscriptionAcquiredState(Subscription subscription)
|
|
QueueEntry.SubscriptionAssignedState(Subscription subscription)
|
|
SubFlushRunner(Subscription sub)
|
Uses of Subscription in org.apache.qpid.server.subscription |
---|
Classes in org.apache.qpid.server.subscription that implement Subscription | |
---|---|
class |
Subscription_0_10
|
class |
SubscriptionImpl
Encapsulation of a supscription to a queue. |
(package private) static class |
SubscriptionImpl.AckSubscription
|
(package private) static class |
SubscriptionImpl.BrowserSubscription
|
static class |
SubscriptionImpl.NoAckSubscription
|
Methods in org.apache.qpid.server.subscription that return Subscription | |
---|---|
Subscription |
SubscriptionFactory.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 |
SubscriptionFactoryImpl.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 |
SubscriptionFactory.createSubscription(int channel,
AMQProtocolSession protocolSession,
org.apache.qpid.framing.AMQShortString consumerTag,
boolean acks,
org.apache.qpid.framing.FieldTable filters,
boolean noLocal,
FlowCreditManager creditManager)
|
Subscription |
SubscriptionFactoryImpl.createSubscription(int channelId,
AMQProtocolSession protocolSession,
org.apache.qpid.framing.AMQShortString consumerTag,
boolean acks,
org.apache.qpid.framing.FieldTable filters,
boolean noLocal,
FlowCreditManager creditManager)
|
Subscription |
SubscriptionList.SubscriptionNode.getSubscription()
|
Methods in org.apache.qpid.server.subscription with parameters of type Subscription | |
---|---|
SubscriptionList.SubscriptionNode |
SubscriptionList.add(Subscription sub)
|
void |
ClientDeliveryMethod.deliverToClient(Subscription sub,
QueueEntry entry,
long deliveryTag)
|
void |
RecordDeliveryMethod.recordMessageDelivery(Subscription sub,
QueueEntry entry,
long deliveryTag)
|
boolean |
SubscriptionList.remove(Subscription sub)
|
void |
Subscription.StateListener.stateChange(Subscription sub,
Subscription.State oldState,
Subscription.State newState)
|
Constructors in org.apache.qpid.server.subscription with parameters of type Subscription | |
---|---|
SubscriptionList.SubscriptionNode(Subscription sub)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |