Package | Description |
---|---|
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.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.region.virtual |
Implementation classes for Virtual Destinations
|
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.network |
Support for federated networks of brokers.
|
org.apache.activemq.plugin | |
org.apache.activemq.security |
Plugable Security Adapter framework along with default implementations such as the JAAS implementation.
|
org.apache.activemq.shiro.authz |
Modifier and Type | Method and Description |
---|---|
Subscription |
AdvisoryBroker.addConsumer(ConnectionContext context,
ConsumerInfo info) |
Modifier and Type | Method and Description |
---|---|
void |
AdvisoryBroker.messageDiscarded(ConnectionContext context,
Subscription sub,
MessageReference messageReference) |
void |
AdvisoryBroker.messageExpired(ConnectionContext context,
MessageReference messageReference,
Subscription subscription) |
boolean |
AdvisoryBroker.sendToDeadLetterQueue(ConnectionContext context,
MessageReference messageReference,
Subscription subscription,
Throwable poisonCause) |
void |
AdvisoryBroker.slowConsumer(ConnectionContext context,
Destination destination,
Subscription subs) |
Modifier and Type | Method and Description |
---|---|
Subscription |
BrokerBroadcaster.addConsumer(ConnectionContext context,
ConsumerInfo info) |
Subscription |
ErrorBroker.addConsumer(ConnectionContext context,
ConsumerInfo info) |
Subscription |
BrokerFilter.addConsumer(ConnectionContext context,
ConsumerInfo info) |
Subscription |
EmptyBroker.addConsumer(ConnectionContext context,
ConsumerInfo info) |
Subscription |
MutableBrokerFilter.addConsumer(ConnectionContext context,
ConsumerInfo info) |
Subscription |
ConsumerBrokerExchange.getSubscription() |
Modifier and Type | Method and Description |
---|---|
void |
ErrorBroker.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 |
BrokerFilter.messageDiscarded(ConnectionContext context,
Subscription sub,
MessageReference messageReference) |
void |
EmptyBroker.messageDiscarded(ConnectionContext context,
Subscription sub,
MessageReference messageReference) |
void |
MutableBrokerFilter.messageDiscarded(ConnectionContext context,
Subscription sub,
MessageReference messageReference) |
void |
ErrorBroker.messageExpired(ConnectionContext context,
MessageReference message,
Subscription subscription) |
void |
Broker.messageExpired(ConnectionContext context,
MessageReference messageReference,
Subscription subscription)
A Message has Expired
|
void |
BrokerFilter.messageExpired(ConnectionContext context,
MessageReference message,
Subscription subscription) |
void |
EmptyBroker.messageExpired(ConnectionContext context,
MessageReference message,
Subscription subscription) |
void |
MutableBrokerFilter.messageExpired(ConnectionContext context,
MessageReference message,
Subscription subscription) |
boolean |
ErrorBroker.sendToDeadLetterQueue(ConnectionContext context,
MessageReference messageReference,
Subscription subscription,
Throwable poisonCause) |
boolean |
Broker.sendToDeadLetterQueue(ConnectionContext context,
MessageReference messageReference,
Subscription subscription,
Throwable poisonCause)
A message needs to go the a DLQ
|
boolean |
BrokerFilter.sendToDeadLetterQueue(ConnectionContext context,
MessageReference messageReference,
Subscription subscription,
Throwable poisonCause) |
boolean |
EmptyBroker.sendToDeadLetterQueue(ConnectionContext context,
MessageReference messageReference,
Subscription subscription,
Throwable poisonCause) |
boolean |
MutableBrokerFilter.sendToDeadLetterQueue(ConnectionContext context,
MessageReference messageReference,
Subscription subscription,
Throwable poisonCause) |
void |
ConsumerBrokerExchange.setSubscription(Subscription subscription) |
void |
ErrorBroker.slowConsumer(ConnectionContext context,
Destination destination,
Subscription subs) |
void |
Broker.slowConsumer(ConnectionContext context,
Destination destination,
Subscription subs)
Called when there is a slow consumer
|
void |
BrokerFilter.slowConsumer(ConnectionContext context,
Destination destination,
Subscription subs) |
void |
EmptyBroker.slowConsumer(ConnectionContext context,
Destination destination,
Subscription subs) |
void |
MutableBrokerFilter.slowConsumer(ConnectionContext context,
Destination dest,
Subscription subs) |
Modifier and Type | Method and Description |
---|---|
Subscription |
ConnectionSplitBroker.addConsumer(ConnectionContext context,
ConsumerInfo info) |
Modifier and Type | Field and Description |
---|---|
protected Subscription |
SubscriptionView.subscription |
Modifier and Type | Method and Description |
---|---|
Subscription |
ManagedRegionBroker.addConsumer(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) |
protected Subscription |
ManagedTempQueueRegion.createSubscription(ConnectionContext context,
ConsumerInfo info) |
Subscription |
ManagedRegionBroker.getSubscriber(ObjectName key) |
Modifier and Type | Method and Description |
---|---|
protected void |
ManagedRegionBroker.addInactiveSubscription(SubscriptionKey key,
SubscriptionInfo info,
Subscription subscription) |
protected void |
ManagedTopicRegion.destroySubscription(Subscription sub) |
protected void |
ManagedQueueRegion.destroySubscription(Subscription sub) |
protected void |
ManagedTempTopicRegion.destroySubscription(Subscription sub) |
protected void |
ManagedTempQueueRegion.destroySubscription(Subscription sub) |
ObjectName |
ManagedRegionBroker.getSubscriberObjectName(Subscription key) |
ObjectName |
ManagedRegionBroker.registerSubscription(ConnectionContext context,
Subscription sub) |
void |
ManagedRegionBroker.unregisterSubscription(Subscription sub) |
Constructor and Description |
---|
DurableSubscriptionView(ManagedRegionBroker broker,
BrokerService brokerService,
String clientId,
String userName,
Subscription sub)
Constructor
|
InactiveDurableSubscriptionView(ManagedRegionBroker broker,
BrokerService brokerService,
String clientId,
SubscriptionInfo subInfo,
Subscription subscription)
Constructor
|
SubscriptionView(String clientId,
String userName,
Subscription subs)
Constructor
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractSubscription |
class |
DurableTopicSubscription |
class |
PrefetchSubscription
A subscription that honors the pre-fetch option of the ConsumerInfo.
|
class |
QueueBrowserSubscription |
class |
QueueSubscription |
class |
TopicSubscription |
Modifier and Type | Field and Description |
---|---|
protected List<Subscription> |
Queue.consumers |
protected CopyOnWriteArrayList<Subscription> |
Topic.consumers |
protected Map<ConsumerId,Subscription> |
AbstractRegion.subscriptions |
Modifier and Type | Method and Description |
---|---|
protected List<Subscription> |
AbstractRegion.addSubscriptionsForDestination(ConnectionContext context,
Destination dest) |
protected List<Subscription> |
TopicRegion.addSubscriptionsForDestination(ConnectionContext context,
Destination dest) |
abstract List<Subscription> |
BaseDestination.getConsumers() |
List<Subscription> |
DestinationFilter.getConsumers() |
List<Subscription> |
Queue.getConsumers() |
List<Subscription> |
Topic.getConsumers() |
List<Subscription> |
Destination.getConsumers() |
Map<ConsumerId,Subscription> |
AbstractRegion.getSubscriptions() |
Modifier and Type | Method and Description |
---|---|
void |
DestinationFilter.acknowledge(ConnectionContext context,
Subscription sub,
MessageAck ack,
MessageReference node) |
void |
Queue.acknowledge(ConnectionContext context,
Subscription sub,
MessageAck ack,
MessageReference node) |
void |
Topic.acknowledge(ConnectionContext context,
Subscription sub,
MessageAck ack,
MessageReference node) |
void |
Destination.acknowledge(ConnectionContext context,
Subscription sub,
MessageAck ack,
MessageReference node) |
void |
BaseDestination.addSubscription(ConnectionContext context,
Subscription sub) |
void |
DestinationFilter.addSubscription(ConnectionContext context,
Subscription sub) |
void |
TempTopic.addSubscription(ConnectionContext context,
Subscription sub) |
void |
Queue.addSubscription(ConnectionContext context,
Subscription sub) |
void |
Topic.addSubscription(ConnectionContext context,
Subscription sub) |
void |
Destination.addSubscription(ConnectionContext context,
Subscription sub) |
void |
TempQueue.addSubscription(ConnectionContext context,
Subscription sub) |
protected void |
Queue.assignGroup(Subscription subs,
MessageGroupMap messageGroupOwners,
MessageReference n,
String groupId) |
protected boolean |
Queue.assignMessageGroup(Subscription subscription,
QueueMessageReference node) |
boolean |
QueueDispatchSelector.canSelect(Subscription subscription,
MessageReference m) |
protected void |
AbstractRegion.destroySubscription(Subscription sub) |
void |
BaseDestination.duplicateFromStore(Message message,
Subscription durableSub) |
void |
DestinationFilter.duplicateFromStore(Message message,
Subscription subscription) |
void |
Destination.duplicateFromStore(Message message,
Subscription subscription) |
boolean |
QueueDispatchSelector.isExclusiveConsumer(Subscription s) |
void |
BaseDestination.messageDiscarded(ConnectionContext context,
Subscription sub,
MessageReference messageReference)
Called when a message is discarded - e.g.
|
void |
DestinationFilter.messageDiscarded(ConnectionContext context,
Subscription sub,
MessageReference messageReference) |
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 |
Queue.messageExpired(ConnectionContext context,
Subscription subs,
MessageReference reference) |
void |
Topic.messageExpired(ConnectionContext context,
Subscription subs,
MessageReference reference) |
void |
Destination.messageExpired(ConnectionContext context,
Subscription subs,
MessageReference node)
Inform the Destination a message has expired
|
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 |
BaseDestination.removeSubscription(ConnectionContext context,
Subscription sub,
long lastDeliveredSequenceId) |
void |
DestinationFilter.removeSubscription(ConnectionContext context,
Subscription sub,
long lastDeliveredSequenceId) |
void |
Queue.removeSubscription(ConnectionContext context,
Subscription sub,
long lastDeliveredSequenceId) |
void |
Topic.removeSubscription(ConnectionContext context,
Subscription sub,
long lastDeliveredSequenceId) |
void |
Destination.removeSubscription(ConnectionContext context,
Subscription sub,
long lastDeliveredSequenceId) |
boolean |
RegionBroker.sendToDeadLetterQueue(ConnectionContext context,
MessageReference node,
Subscription subscription,
Throwable poisonCause) |
void |
QueueDispatchSelector.setExclusiveConsumer(Subscription exclusiveConsumer) |
void |
BaseDestination.slowConsumer(ConnectionContext context,
Subscription subs)
Called when there is a slow consumer
|
void |
DestinationFilter.slowConsumer(ConnectionContext context,
Subscription subs) |
void |
Destination.slowConsumer(ConnectionContext context,
Subscription subs)
Called when there is a slow consumer
|
Modifier and Type | Method and Description |
---|---|
protected boolean |
BaseDestination.hasRegularConsumers(List<Subscription> consumers) |
Modifier and Type | Method and Description |
---|---|
Subscription |
AbstractStoreCursor.getSubscription() |
Modifier and Type | Method and Description |
---|---|
static boolean |
AbstractPendingMessageCursor.isPrioritizedMessageSubscriber(Broker broker,
Subscription sub) |
Modifier and Type | Field and Description |
---|---|
protected Map<Subscription,SlowConsumerEntry> |
AbortSlowConsumerStrategy.slowConsumers |
Modifier and Type | Method and Description |
---|---|
Map<Subscription,SlowConsumerEntry> |
AbortSlowConsumerStrategy.getSlowConsumers() |
Modifier and Type | Method and Description |
---|---|
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) |
void |
PolicyEntry.configurePrefetch(Subscription subscription) |
protected ActiveMQDestination |
IndividualDeadLetterStrategy.createDestination(Message message,
String prefix,
String suffix,
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 |
VMPendingSubscriberMessageStoragePolicy.getSubscriberPendingMessageCursor(Broker broker,
String name,
int maxBatchSize,
Subscription subs) |
PendingMessageCursor |
PendingSubscriberMessageStoragePolicy.getSubscriberPendingMessageCursor(Broker broker,
String name,
int maxBatchSize,
Subscription subs)
Retrieve the configured pending message storage cursor;
|
PendingMessageCursor |
FilePendingSubscriberMessageStoragePolicy.getSubscriberPendingMessageCursor(Broker broker,
String name,
int maxBatchSize,
Subscription subs) |
void |
AbortSlowAckConsumerStrategy.slowConsumer(ConnectionContext context,
Subscription subs) |
void |
SlowConsumerStrategy.slowConsumer(ConnectionContext context,
Subscription subs)
Slow consumer event.
|
void |
AbortSlowConsumerStrategy.slowConsumer(ConnectionContext context,
Subscription subs) |
Modifier and Type | Method and Description |
---|---|
protected void |
AbortSlowConsumerStrategy.abortSubscription(Map<Subscription,SlowConsumerEntry> toAbort,
boolean abortSubscriberConnection) |
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 |
PriorityNetworkDispatchPolicy.dispatch(MessageReference node,
MessageEvaluationContext msgContext,
List<Subscription> consumers) |
boolean |
PriorityDispatchPolicy.dispatch(MessageReference node,
MessageEvaluationContext msgContext,
List<Subscription> consumers) |
boolean |
RoundRobinDispatchPolicy.dispatch(MessageReference node,
MessageEvaluationContext msgContext,
List<Subscription> consumers) |
Modifier and Type | Method and Description |
---|---|
void |
MappedQueueFilter.addSubscription(ConnectionContext context,
Subscription sub) |
void |
MappedQueueFilter.removeSubscription(ConnectionContext context,
Subscription sub,
long lastDeliveredSequenceId) |
Modifier and Type | Method and Description |
---|---|
Subscription |
LoggingBrokerPlugin.addConsumer(ConnectionContext context,
ConsumerInfo info) |
Subscription |
DestinationPathSeparatorBroker.addConsumer(ConnectionContext context,
ConsumerInfo info) |
Subscription |
UDPTraceBrokerPlugin.addConsumer(ConnectionContext context,
ConsumerInfo info) |
Modifier and Type | Method and Description |
---|---|
void |
LoggingBrokerPlugin.messageDiscarded(ConnectionContext context,
Subscription sub,
MessageReference messageReference) |
void |
LoggingBrokerPlugin.messageExpired(ConnectionContext context,
MessageReference message,
Subscription subscription) |
boolean |
LoggingBrokerPlugin.sendToDeadLetterQueue(ConnectionContext context,
MessageReference messageReference,
Subscription subscription,
Throwable poisonCause) |
boolean |
RedeliveryPlugin.sendToDeadLetterQueue(ConnectionContext context,
MessageReference messageReference,
Subscription subscription,
Throwable poisonCause) |
void |
LoggingBrokerPlugin.slowConsumer(ConnectionContext context,
Destination destination,
Subscription subs) |
Modifier and Type | Method and Description |
---|---|
Subscription |
ConnectionDotFileInterceptor.addConsumer(ConnectionContext context,
ConsumerInfo info) |
Modifier and Type | Method and Description |
---|---|
List<MessageReference> |
DestinationBasedMessageList.getMessages(Subscription sub) |
Modifier and Type | Method and Description |
---|---|
protected Collection<Subscription> |
DemandForwardingBridgeSupport.getRegionSubscriptions(ActiveMQDestination dest) |
Modifier and Type | Method and Description |
---|---|
Subscription |
SubQueueSelectorCacheBroker.addConsumer(ConnectionContext context,
ConsumerInfo info) |
Modifier and Type | Method and Description |
---|---|
boolean |
DiscardingDLQBroker.sendToDeadLetterQueue(ConnectionContext ctx,
MessageReference msgRef,
Subscription subscription,
Throwable poisonCause) |
Modifier and Type | Method and Description |
---|---|
Subscription |
AuthorizationBroker.addConsumer(ConnectionContext context,
ConsumerInfo info) |
Modifier and Type | Method and Description |
---|---|
void |
AuthorizationDestinationFilter.addSubscription(ConnectionContext context,
Subscription sub) |
Modifier and Type | Method and Description |
---|---|
Subscription |
AuthorizationFilter.addConsumer(ConnectionContext context,
ConsumerInfo info) |
Copyright © 2005–2017. All rights reserved.