|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use Subscription | |
---|---|
org.apache.activemq.advisory | Support for JMS Advisory messages as well as some helper listeners to listen to the clients, producers and consumers available. |
org.apache.activemq.broker | The core classes for the ActiveMQ Message Broker and its connectors. |
org.apache.activemq.broker.cluster | |
org.apache.activemq.broker.ft | Helper classes for implementing fault tolerance |
org.apache.activemq.broker.jmx | JMX MBeans for the broker and its core connectors. |
org.apache.activemq.broker.region | Region abstraction and implementations in the Broker. |
org.apache.activemq.broker.region.cursors | Cursors used to page persistent messages into the broker from the store |
org.apache.activemq.broker.region.policy | The policies which can be associated with a particular destination or wildcard. |
org.apache.activemq.broker.util | Some utility Broker Plugins |
org.apache.activemq.broker.view | Broker Plugins for visualising the current system |
org.apache.activemq.memory.list | |
org.apache.activemq.plugin | |
org.apache.activemq.security | Plugable Security Adapter framework along with default implementations such as the JAAS implementation. |
Uses of Subscription in org.apache.activemq.advisory |
---|
Methods in org.apache.activemq.advisory that return Subscription | |
---|---|
Subscription |
AdvisoryBroker.addConsumer(ConnectionContext context,
ConsumerInfo info)
|
Methods in org.apache.activemq.advisory with parameters of type Subscription | |
---|---|
void |
AdvisoryBroker.messageDiscarded(ConnectionContext context,
Subscription sub,
MessageReference messageReference)
|
void |
AdvisoryBroker.messageExpired(ConnectionContext context,
MessageReference messageReference,
Subscription subscription)
|
void |
AdvisoryBroker.sendToDeadLetterQueue(ConnectionContext context,
MessageReference messageReference,
Subscription subscription)
|
void |
AdvisoryBroker.slowConsumer(ConnectionContext context,
Destination destination,
Subscription subs)
|
Uses of Subscription in org.apache.activemq.broker |
---|
Methods in org.apache.activemq.broker that return Subscription | |
---|---|
Subscription |
ErrorBroker.addConsumer(ConnectionContext context,
ConsumerInfo info)
|
Subscription |
BrokerBroadcaster.addConsumer(ConnectionContext context,
ConsumerInfo info)
|
Subscription |
BrokerFilter.addConsumer(ConnectionContext context,
ConsumerInfo info)
|
Subscription |
MutableBrokerFilter.addConsumer(ConnectionContext context,
ConsumerInfo info)
|
Subscription |
EmptyBroker.addConsumer(ConnectionContext context,
ConsumerInfo info)
|
Subscription |
ConsumerBrokerExchange.getSubscription()
|
Methods in org.apache.activemq.broker with parameters of type Subscription | |
---|---|
void |
ErrorBroker.messageDiscarded(ConnectionContext context,
Subscription sub,
MessageReference messageReference)
|
void |
BrokerFilter.messageDiscarded(ConnectionContext context,
Subscription sub,
MessageReference messageReference)
|
void |
MutableBrokerFilter.messageDiscarded(ConnectionContext context,
Subscription sub,
MessageReference messageReference)
|
void |
EmptyBroker.messageDiscarded(ConnectionContext context,
Subscription sub,
MessageReference messageReference)
|
void |
Broker.messageDiscarded(ConnectionContext context,
Subscription sub,
MessageReference messageReference)
Called when a message is discarded - e.g. |
void |
ErrorBroker.messageExpired(ConnectionContext context,
MessageReference message,
Subscription subscription)
|
void |
BrokerFilter.messageExpired(ConnectionContext context,
MessageReference message,
Subscription subscription)
|
void |
MutableBrokerFilter.messageExpired(ConnectionContext context,
MessageReference message,
Subscription subscription)
|
void |
EmptyBroker.messageExpired(ConnectionContext context,
MessageReference message,
Subscription subscription)
|
void |
Broker.messageExpired(ConnectionContext context,
MessageReference messageReference,
Subscription subscription)
A Message has Expired |
void |
ErrorBroker.sendToDeadLetterQueue(ConnectionContext context,
MessageReference messageReference,
Subscription subscription)
|
void |
BrokerFilter.sendToDeadLetterQueue(ConnectionContext context,
MessageReference messageReference,
Subscription subscription)
|
void |
MutableBrokerFilter.sendToDeadLetterQueue(ConnectionContext context,
MessageReference messageReference,
Subscription subscription)
|
void |
EmptyBroker.sendToDeadLetterQueue(ConnectionContext context,
MessageReference messageReference,
Subscription subscription)
|
void |
Broker.sendToDeadLetterQueue(ConnectionContext context,
MessageReference messageReference,
Subscription subscription)
A message needs to go the a DLQ |
void |
ConsumerBrokerExchange.setSubscription(Subscription subscription)
|
void |
ErrorBroker.slowConsumer(ConnectionContext context,
Destination destination,
Subscription subs)
|
void |
BrokerFilter.slowConsumer(ConnectionContext context,
Destination destination,
Subscription subs)
|
void |
MutableBrokerFilter.slowConsumer(ConnectionContext context,
Destination dest,
Subscription subs)
|
void |
EmptyBroker.slowConsumer(ConnectionContext context,
Destination destination,
Subscription subs)
|
void |
Broker.slowConsumer(ConnectionContext context,
Destination destination,
Subscription subs)
Called when there is a slow consumer |
Uses of Subscription in org.apache.activemq.broker.cluster |
---|
Methods in org.apache.activemq.broker.cluster that return Subscription | |
---|---|
Subscription |
ConnectionSplitBroker.addConsumer(ConnectionContext context,
ConsumerInfo info)
|
Uses of Subscription in org.apache.activemq.broker.ft |
---|
Methods in org.apache.activemq.broker.ft that return Subscription | |
---|---|
Subscription |
MasterBroker.addConsumer(ConnectionContext context,
ConsumerInfo info)
add a consumer |
Uses of Subscription in org.apache.activemq.broker.jmx |
---|
Fields in org.apache.activemq.broker.jmx declared as Subscription | |
---|---|
protected Subscription |
SubscriptionView.subscription
|
Methods in org.apache.activemq.broker.jmx that return Subscription | |
---|---|
Subscription |
ManagedRegionBroker.addConsumer(ConnectionContext context,
ConsumerInfo info)
|
protected Subscription |
ManagedTempTopicRegion.createSubscription(ConnectionContext context,
ConsumerInfo info)
|
protected Subscription |
ManagedTempQueueRegion.createSubscription(ConnectionContext context,
ConsumerInfo info)
|
protected Subscription |
ManagedQueueRegion.createSubscription(ConnectionContext context,
ConsumerInfo info)
|
protected Subscription |
ManagedTopicRegion.createSubscription(ConnectionContext context,
ConsumerInfo info)
|
Subscription |
ManagedRegionBroker.getSubscriber(javax.management.ObjectName key)
|
Methods in org.apache.activemq.broker.jmx with parameters of type Subscription | |
---|---|
protected void |
ManagedTempTopicRegion.destroySubscription(Subscription sub)
|
protected void |
ManagedTempQueueRegion.destroySubscription(Subscription sub)
|
protected void |
ManagedQueueRegion.destroySubscription(Subscription sub)
|
protected void |
ManagedTopicRegion.destroySubscription(Subscription sub)
|
javax.management.ObjectName |
ManagedRegionBroker.getSubscriberObjectName(Subscription key)
|
static java.lang.String |
ManagedRegionBroker.getSubscriptionObjectName(Subscription sub,
java.lang.String connectionClientId,
javax.management.ObjectName brokerJmxObjectName)
|
javax.management.ObjectName |
ManagedRegionBroker.registerSubscription(ConnectionContext context,
Subscription sub)
|
void |
ManagedRegionBroker.unregisterSubscription(Subscription sub)
|
Constructors in org.apache.activemq.broker.jmx with parameters of type Subscription | |
---|---|
DurableSubscriptionView(ManagedRegionBroker broker,
java.lang.String clientId,
Subscription sub)
Constructor |
|
SubscriptionView(java.lang.String clientId,
Subscription subs)
Constructor |
Uses of Subscription in org.apache.activemq.broker.region |
---|
Classes in org.apache.activemq.broker.region that implement Subscription | |
---|---|
class |
AbstractSubscription
|
class |
DurableTopicSubscription
|
class |
PrefetchSubscription
A subscription that honors the pre-fetch option of the ConsumerInfo. |
class |
QueueBrowserSubscription
|
class |
QueueSubscription
|
class |
TopicSubscription
|
Fields in org.apache.activemq.broker.region with type parameters of type Subscription | |
---|---|
protected java.util.concurrent.CopyOnWriteArrayList<Subscription> |
Topic.consumers
|
protected java.util.List<Subscription> |
Queue.consumers
|
protected java.util.Map<ConsumerId,Subscription> |
AbstractRegion.subscriptions
|
Methods in org.apache.activemq.broker.region that return Subscription | |
---|---|
Subscription |
AbstractRegion.addConsumer(ConnectionContext context,
ConsumerInfo info)
|
Subscription |
TopicRegion.addConsumer(ConnectionContext context,
ConsumerInfo info)
|
Subscription |
RegionBroker.addConsumer(ConnectionContext context,
ConsumerInfo info)
|
Subscription |
Region.addConsumer(ConnectionContext context,
ConsumerInfo info)
Adds a consumer. |
protected Subscription |
TempQueueRegion.createSubscription(ConnectionContext context,
ConsumerInfo info)
|
protected Subscription |
TempTopicRegion.createSubscription(ConnectionContext context,
ConsumerInfo info)
|
protected Subscription |
QueueRegion.createSubscription(ConnectionContext context,
ConsumerInfo info)
|
protected abstract Subscription |
AbstractRegion.createSubscription(ConnectionContext context,
ConsumerInfo info)
|
protected Subscription |
TopicRegion.createSubscription(ConnectionContext context,
ConsumerInfo info)
|
Subscription |
QueueDispatchSelector.getExclusiveConsumer()
|
Methods in org.apache.activemq.broker.region that return types with arguments of type Subscription | |
---|---|
protected java.util.List<Subscription> |
AbstractRegion.addSubscriptionsForDestination(ConnectionContext context,
Destination dest)
|
protected java.util.List<Subscription> |
TopicRegion.addSubscriptionsForDestination(ConnectionContext context,
Destination dest)
|
java.util.List<Subscription> |
DestinationFilter.getConsumers()
|
java.util.List<Subscription> |
Topic.getConsumers()
|
java.util.List<Subscription> |
Queue.getConsumers()
|
java.util.List<Subscription> |
Destination.getConsumers()
|
java.util.Map<ConsumerId,Subscription> |
AbstractRegion.getSubscriptions()
|
Methods in org.apache.activemq.broker.region with parameters of type Subscription | |
---|---|
void |
DestinationFilter.acknowledge(ConnectionContext context,
Subscription sub,
MessageAck ack,
MessageReference node)
|
void |
Topic.acknowledge(ConnectionContext context,
Subscription sub,
MessageAck ack,
MessageReference node)
|
void |
Queue.acknowledge(ConnectionContext context,
Subscription sub,
MessageAck ack,
MessageReference node)
|
void |
Destination.acknowledge(ConnectionContext context,
Subscription sub,
MessageAck ack,
MessageReference node)
|
void |
TempTopic.addSubscription(ConnectionContext context,
Subscription sub)
|
void |
DestinationFilter.addSubscription(ConnectionContext context,
Subscription sub)
|
void |
TempQueue.addSubscription(ConnectionContext context,
Subscription sub)
|
void |
Topic.addSubscription(ConnectionContext context,
Subscription sub)
|
void |
BaseDestination.addSubscription(ConnectionContext context,
Subscription sub)
|
void |
Queue.addSubscription(ConnectionContext context,
Subscription sub)
|
void |
Destination.addSubscription(ConnectionContext context,
Subscription sub)
|
protected void |
Queue.assignGroup(Subscription subs,
MessageGroupMap messageGroupOwners,
MessageReference n,
java.lang.String groupId)
|
protected boolean |
Queue.assignMessageGroup(Subscription subscription,
QueueMessageReference node)
|
boolean |
QueueDispatchSelector.canSelect(Subscription subscription,
MessageReference m)
|
protected void |
AbstractRegion.destroySubscription(Subscription sub)
|
boolean |
QueueDispatchSelector.isExclusiveConsumer(Subscription s)
|
void |
DestinationFilter.messageDiscarded(ConnectionContext context,
Subscription sub,
MessageReference messageReference)
|
void |
BaseDestination.messageDiscarded(ConnectionContext context,
Subscription sub,
MessageReference messageReference)
Called when a message is discarded - e.g. |
void |
Destination.messageDiscarded(ConnectionContext context,
Subscription sub,
MessageReference messageReference)
Called when a message is discarded - e.g. |
void |
RegionBroker.messageExpired(ConnectionContext context,
MessageReference node,
Subscription subscription)
|
void |
DestinationFilter.messageExpired(ConnectionContext context,
Subscription subs,
MessageReference node)
|
void |
Topic.messageExpired(ConnectionContext context,
Subscription subs,
MessageReference reference)
|
void |
Queue.messageExpired(ConnectionContext context,
Subscription subs,
MessageReference reference)
|
void |
Destination.messageExpired(ConnectionContext context,
Subscription subs,
MessageReference node)
Inform the Destination a message has expired |
protected void |
Topic.recoverRetroactiveMessages(ConnectionContext context,
Subscription subscription)
|
protected void |
Queue.removeMessage(ConnectionContext c,
Subscription subs,
QueueMessageReference r)
|
protected void |
Queue.removeMessage(ConnectionContext context,
Subscription sub,
QueueMessageReference reference,
MessageAck ack)
|
void |
DestinationFilter.removeSubscription(ConnectionContext context,
Subscription sub,
long lastDeliveredSequenceId)
|
void |
Topic.removeSubscription(ConnectionContext context,
Subscription sub,
long lastDeliveredSequenceId)
|
void |
BaseDestination.removeSubscription(ConnectionContext context,
Subscription sub,
long lastDeliveredSequenceId)
|
void |
Queue.removeSubscription(ConnectionContext context,
Subscription sub,
long lastDeiveredSequenceId)
|
void |
Destination.removeSubscription(ConnectionContext context,
Subscription sub,
long lastDeliveredSequenceId)
|
void |
RegionBroker.sendToDeadLetterQueue(ConnectionContext context,
MessageReference node,
Subscription subscription)
|
void |
QueueDispatchSelector.setExclusiveConsumer(Subscription exclusiveConsumer)
|
void |
DestinationFilter.slowConsumer(ConnectionContext context,
Subscription subs)
|
void |
BaseDestination.slowConsumer(ConnectionContext context,
Subscription subs)
Called when there is a slow consumer |
void |
Destination.slowConsumer(ConnectionContext context,
Subscription subs)
Called when there is a slow consumer |
Uses of Subscription in org.apache.activemq.broker.region.cursors |
---|
Methods in org.apache.activemq.broker.region.cursors with parameters of type Subscription | |
---|---|
static boolean |
AbstractPendingMessageCursor.isPrioritizedMessageSubscriber(Broker broker,
Subscription sub)
|
Uses of Subscription in org.apache.activemq.broker.region.policy |
---|
Methods in org.apache.activemq.broker.region.policy that return types with arguments of type Subscription | |
---|---|
java.util.Map<Subscription,SlowConsumerEntry> |
AbortSlowConsumerStrategy.getSlowConsumers()
|
Methods in org.apache.activemq.broker.region.policy with parameters of type Subscription | |
---|---|
void |
AbortSlowConsumerStrategy.abortConsumer(Subscription sub,
boolean abortSubscriberConnection)
|
boolean |
DispatchSelector.canDispatch(Subscription subscription,
MessageReference node)
return true if a subscription can dispatch a message reference |
boolean |
SimpleDispatchSelector.canDispatch(Subscription subscription,
MessageReference node)
|
protected ActiveMQDestination |
IndividualDeadLetterStrategy.createDestination(Message message,
java.lang.String prefix,
boolean useQueue,
Subscription subscription)
|
ActiveMQDestination |
IndividualDeadLetterStrategy.getDeadLetterQueueFor(Message message,
Subscription subscription)
|
ActiveMQDestination |
SharedDeadLetterStrategy.getDeadLetterQueueFor(Message message,
Subscription subscription)
|
ActiveMQDestination |
DeadLetterStrategy.getDeadLetterQueueFor(Message message,
Subscription subscription)
Returns the dead letter queue for the given message and subscription. |
PendingMessageCursor |
FilePendingSubscriberMessageStoragePolicy.getSubscriberPendingMessageCursor(Broker broker,
java.lang.String name,
int maxBatchSize,
Subscription subs)
|
PendingMessageCursor |
VMPendingSubscriberMessageStoragePolicy.getSubscriberPendingMessageCursor(Broker broker,
java.lang.String name,
int maxBatchSize,
Subscription subs)
|
PendingMessageCursor |
PendingSubscriberMessageStoragePolicy.getSubscriberPendingMessageCursor(Broker broker,
java.lang.String name,
int maxBatchSize,
Subscription subs)
Retrieve the configured pending message storage cursor; |
void |
AbortSlowConsumerStrategy.slowConsumer(ConnectionContext context,
Subscription subs)
|
void |
SlowConsumerStrategy.slowConsumer(ConnectionContext context,
Subscription subs)
|
Method parameters in org.apache.activemq.broker.region.policy with type arguments of type Subscription | |
---|---|
boolean |
PriorityNetworkDispatchPolicy.dispatch(MessageReference node,
MessageEvaluationContext msgContext,
java.util.List<Subscription> consumers)
|
boolean |
RoundRobinDispatchPolicy.dispatch(MessageReference node,
MessageEvaluationContext msgContext,
java.util.List<Subscription> consumers)
|
boolean |
SimpleDispatchPolicy.dispatch(MessageReference node,
MessageEvaluationContext msgContext,
java.util.List<Subscription> consumers)
|
boolean |
DispatchPolicy.dispatch(MessageReference node,
MessageEvaluationContext msgContext,
java.util.List<Subscription> consumers)
Decides how to dispatch a selected message to a collection of consumers. |
Uses of Subscription in org.apache.activemq.broker.util |
---|
Methods in org.apache.activemq.broker.util that return Subscription | |
---|---|
Subscription |
UDPTraceBrokerPlugin.addConsumer(ConnectionContext context,
ConsumerInfo info)
|
Subscription |
DestinationPathSeparatorBroker.addConsumer(ConnectionContext context,
ConsumerInfo info)
|
Subscription |
LoggingBrokerPlugin.addConsumer(ConnectionContext context,
ConsumerInfo info)
|
Methods in org.apache.activemq.broker.util with parameters of type Subscription | |
---|---|
void |
LoggingBrokerPlugin.messageDiscarded(ConnectionContext context,
Subscription sub,
MessageReference messageReference)
|
void |
LoggingBrokerPlugin.messageExpired(ConnectionContext context,
MessageReference message,
Subscription subscription)
|
void |
LoggingBrokerPlugin.sendToDeadLetterQueue(ConnectionContext context,
MessageReference messageReference,
Subscription subscription)
|
void |
LoggingBrokerPlugin.slowConsumer(ConnectionContext context,
Destination destination,
Subscription subs)
|
Uses of Subscription in org.apache.activemq.broker.view |
---|
Methods in org.apache.activemq.broker.view that return Subscription | |
---|---|
Subscription |
ConnectionDotFileInterceptor.addConsumer(ConnectionContext context,
ConsumerInfo info)
|
Uses of Subscription in org.apache.activemq.memory.list |
---|
Methods in org.apache.activemq.memory.list with parameters of type Subscription | |
---|---|
java.util.List<MessageReference> |
DestinationBasedMessageList.getMessages(Subscription sub)
|
Uses of Subscription in org.apache.activemq.plugin |
---|
Methods in org.apache.activemq.plugin with parameters of type Subscription | |
---|---|
void |
DiscardingDLQBroker.sendToDeadLetterQueue(ConnectionContext ctx,
MessageReference msgRef,
Subscription subscription)
|
Uses of Subscription in org.apache.activemq.security |
---|
Methods in org.apache.activemq.security that return Subscription | |
---|---|
Subscription |
AuthorizationBroker.addConsumer(ConnectionContext context,
ConsumerInfo info)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |