|
||||||||||
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.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.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 |
EmptyBroker.addConsumer(ConnectionContext context,
ConsumerInfo info)
|
Subscription |
MutableBrokerFilter.addConsumer(ConnectionContext context,
ConsumerInfo info)
|
Subscription |
BrokerFilter.addConsumer(ConnectionContext context,
ConsumerInfo info)
|
Subscription |
BrokerBroadcaster.addConsumer(ConnectionContext context,
ConsumerInfo info)
|
Subscription |
ErrorBroker.addConsumer(ConnectionContext context,
ConsumerInfo info)
|
Subscription |
ConsumerBrokerExchange.getSubscription()
|
Methods in org.apache.activemq.broker with parameters of type Subscription | |
---|---|
void |
ConsumerBrokerExchange.setSubscription(Subscription subscription)
|
void |
Broker.slowConsumer(ConnectionContext context,
Destination destination,
Subscription subs)
Called when there is a slow consumer |
void |
EmptyBroker.slowConsumer(ConnectionContext context,
Destination destination,
Subscription subs)
|
void |
MutableBrokerFilter.slowConsumer(ConnectionContext context,
Destination dest,
Subscription subs)
|
void |
BrokerFilter.slowConsumer(ConnectionContext context,
Destination destination,
Subscription subs)
|
void |
ErrorBroker.slowConsumer(ConnectionContext context,
Destination destination,
Subscription subs)
|
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 | |
---|---|
protected Subscription |
ManagedTempQueueRegion.createSubscription(ConnectionContext context,
ConsumerInfo info)
|
protected Subscription |
ManagedTopicRegion.createSubscription(ConnectionContext context,
ConsumerInfo info)
|
protected Subscription |
ManagedQueueRegion.createSubscription(ConnectionContext context,
ConsumerInfo info)
|
protected Subscription |
ManagedTempTopicRegion.createSubscription(ConnectionContext context,
ConsumerInfo info)
|
Methods in org.apache.activemq.broker.jmx with parameters of type Subscription | |
---|---|
protected void |
ManagedTempQueueRegion.destroySubscription(Subscription sub)
|
protected void |
ManagedTopicRegion.destroySubscription(Subscription sub)
|
protected void |
ManagedQueueRegion.destroySubscription(Subscription sub)
|
protected void |
ManagedTempTopicRegion.destroySubscription(Subscription sub)
|
static String |
ManagedRegionBroker.getSubscriptionObjectName(Subscription sub,
String connectionClientId,
ObjectName brokerJmxObjectName)
|
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,
String clientId,
Subscription sub)
Constructor |
|
SubscriptionView(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 CopyOnWriteArrayList<Subscription> |
Topic.consumers
|
protected List<Subscription> |
Queue.consumers
|
protected Map<ConsumerId,Subscription> |
AbstractRegion.subscriptions
|
Methods in org.apache.activemq.broker.region that return Subscription | |
---|---|
Subscription |
Region.addConsumer(ConnectionContext context,
ConsumerInfo info)
Adds a consumer. |
Subscription |
AbstractRegion.addConsumer(ConnectionContext context,
ConsumerInfo info)
|
Subscription |
TopicRegion.addConsumer(ConnectionContext context,
ConsumerInfo info)
|
Subscription |
RegionBroker.addConsumer(ConnectionContext context,
ConsumerInfo info)
|
protected abstract Subscription |
AbstractRegion.createSubscription(ConnectionContext context,
ConsumerInfo info)
|
protected Subscription |
TopicRegion.createSubscription(ConnectionContext context,
ConsumerInfo info)
|
protected Subscription |
QueueRegion.createSubscription(ConnectionContext context,
ConsumerInfo info)
|
protected Subscription |
TempQueueRegion.createSubscription(ConnectionContext context,
ConsumerInfo info)
|
protected Subscription |
TempTopicRegion.createSubscription(ConnectionContext context,
ConsumerInfo info)
|
Subscription |
QueueDispatchSelector.getExclusiveConsumer()
|
Methods in org.apache.activemq.broker.region that return types with arguments of type Subscription | |
---|---|
protected List<Subscription> |
AbstractRegion.addSubscriptionsForDestination(ConnectionContext context,
Destination dest)
|
protected List<Subscription> |
TopicRegion.addSubscriptionsForDestination(ConnectionContext context,
Destination dest)
|
List<Subscription> |
Destination.getConsumers()
|
List<Subscription> |
Topic.getConsumers()
|
List<Subscription> |
DestinationFilter.getConsumers()
|
List<Subscription> |
Queue.getConsumers()
|
Map<ConsumerId,Subscription> |
AbstractRegion.getSubscriptions()
|
Uses of Subscription in org.apache.activemq.broker.region.cursors |
---|
Constructors in org.apache.activemq.broker.region.cursors with parameters of type Subscription | |
---|---|
StoreDurableSubscriberCursor(Broker broker,
String clientId,
String subscriberName,
int maxBatchSize,
Subscription subscription)
|
Uses of Subscription in org.apache.activemq.broker.region.policy |
---|
Methods in org.apache.activemq.broker.region.policy with parameters of type Subscription | |
---|---|
boolean |
SimpleDispatchSelector.canDispatch(Subscription subscription,
MessageReference node)
|
boolean |
DispatchSelector.canDispatch(Subscription subscription,
MessageReference node)
return true if a subscription can dispatch a message reference |
PendingMessageCursor |
PendingDurableSubscriberMessageStoragePolicy.getSubscriberPendingMessageCursor(Broker broker,
String clientId,
String name,
int maxBatchSize,
Subscription sub)
Retrieve the configured pending message storage cursor; |
PendingMessageCursor |
VMPendingDurableSubscriberMessageStoragePolicy.getSubscriberPendingMessageCursor(Broker broker,
String clientId,
String name,
int maxBatchSize,
Subscription sub)
Retrieve the configured pending message storage cursor; |
PendingMessageCursor |
FilePendingDurableSubscriberMessageStoragePolicy.getSubscriberPendingMessageCursor(Broker broker,
String clientId,
String name,
int maxBatchSize,
Subscription sub)
Retrieve the configured pending message storage cursor; |
PendingMessageCursor |
StorePendingDurableSubscriberMessageStoragePolicy.getSubscriberPendingMessageCursor(Broker broker,
String clientId,
String name,
int maxBatchSize,
Subscription sub)
Retrieve the configured pending message storage cursor; |
Method parameters in org.apache.activemq.broker.region.policy with type arguments of type Subscription | |
---|---|
boolean |
DispatchPolicy.dispatch(MessageReference node,
MessageEvaluationContext msgContext,
List<Subscription> consumers)
Decides how to dispatch a selected message to a collection of consumers. |
boolean |
SimpleDispatchPolicy.dispatch(MessageReference node,
MessageEvaluationContext msgContext,
List<Subscription> consumers)
|
boolean |
RoundRobinDispatchPolicy.dispatch(MessageReference node,
MessageEvaluationContext msgContext,
List<Subscription> 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 |
LoggingBrokerPlugin.addConsumer(ConnectionContext context,
ConsumerInfo info)
|
Methods in org.apache.activemq.broker.util with parameters of type 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 | |
---|---|
List<MessageReference> |
DestinationBasedMessageList.getMessages(Subscription sub)
|
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 |