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.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.group |
Classes to implement the Message Groups feature.
|
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.security |
Plugable Security Adapter framework along with default implementations such as the JAAS implementation.
|
org.apache.activemq.shiro.authz | |
org.apache.activemq.store.kahadb |
Modifier and Type | Method and Description |
---|---|
Destination |
AdvisoryBroker.addDestination(ConnectionContext context,
ActiveMQDestination destination,
boolean create) |
Modifier and Type | Method and Description |
---|---|
void |
AdvisoryBroker.isFull(ConnectionContext context,
Destination destination,
Usage usage) |
void |
AdvisoryBroker.slowConsumer(ConnectionContext context,
Destination destination,
Subscription subs) |
Modifier and Type | Method and Description |
---|---|
Destination |
MutableBrokerFilter.addDestination(ConnectionContext context,
ActiveMQDestination destination,
boolean createIfTemporary) |
Destination |
ErrorBroker.addDestination(ConnectionContext context,
ActiveMQDestination destination,
boolean flag) |
Destination |
EmptyBroker.addDestination(ConnectionContext context,
ActiveMQDestination destination,
boolean flag) |
Destination |
BrokerFilter.addDestination(ConnectionContext context,
ActiveMQDestination destination,
boolean createIfTemporary) |
Destination |
BrokerBroadcaster.addDestination(ConnectionContext context,
ActiveMQDestination destination,
boolean createIfTemporary) |
Destination |
BrokerService.getDestination(ActiveMQDestination destination)
Looks up and lazily creates if necessary the destination for the given
JMS name
|
Destination |
ProducerBrokerExchange.getRegionDestination() |
Destination |
ConsumerBrokerExchange.getRegionDestination() |
Modifier and Type | Method and Description |
---|---|
void |
ProducerBrokerExchange.incrementTimeBlocked(Destination destination,
long timeBlocked) |
void |
MutableBrokerFilter.isFull(ConnectionContext context,
Destination destination,
Usage usage) |
void |
ErrorBroker.isFull(ConnectionContext context,
Destination destination,
Usage usage) |
void |
EmptyBroker.isFull(ConnectionContext context,
Destination destination,
Usage usage) |
void |
BrokerFilter.isFull(ConnectionContext context,
Destination destination,
Usage usage) |
void |
Broker.isFull(ConnectionContext context,
Destination destination,
Usage usage)
Called when a Usage reaches a limit
|
void |
ProducerBrokerExchange.setRegionDestination(Destination regionDestination) |
void |
ConsumerBrokerExchange.setRegionDestination(Destination regionDestination) |
void |
MutableBrokerFilter.slowConsumer(ConnectionContext context,
Destination dest,
Subscription subs) |
void |
ErrorBroker.slowConsumer(ConnectionContext context,
Destination destination,
Subscription subs) |
void |
EmptyBroker.slowConsumer(ConnectionContext context,
Destination destination,
Subscription subs) |
void |
BrokerFilter.slowConsumer(ConnectionContext context,
Destination destination,
Subscription subs) |
void |
Broker.slowConsumer(ConnectionContext context,
Destination destination,
Subscription subs)
Called when there is a slow consumer
|
Modifier and Type | Field and Description |
---|---|
protected Destination |
DestinationView.destination |
Modifier and Type | Method and Description |
---|---|
protected Destination |
ManagedTempTopicRegion.createDestination(ConnectionContext context,
ActiveMQDestination destination) |
protected Destination |
ManagedTopicRegion.createDestination(ConnectionContext context,
ActiveMQDestination destination) |
protected Destination |
ManagedQueueRegion.createDestination(ConnectionContext context,
ActiveMQDestination destination) |
protected Destination |
ManagedTempQueueRegion.createDestination(ConnectionContext context,
ActiveMQDestination destination) |
Modifier and Type | Method and Description |
---|---|
void |
ManagedRegionBroker.register(ActiveMQDestination destName,
Destination destination) |
Constructor and Description |
---|
DestinationView(ManagedRegionBroker broker,
Destination destination) |
Modifier and Type | Class and Description |
---|---|
class |
BaseDestination |
class |
DestinationFilter |
class |
Queue
The Queue is a List of MessageEntry objects that are dispatched to matching
subscriptions.
|
class |
TempQueue
The Queue is a List of MessageEntry objects that are dispatched to matching
subscriptions.
|
class |
TempTopic
The Topic is a destination that sends a copy of a message to every active
Subscription registered.
|
class |
Topic
The Topic is a destination that sends a copy of a message to every active
Subscription registered.
|
Modifier and Type | Field and Description |
---|---|
protected Destination |
DestinationFilter.next |
Modifier and Type | Field and Description |
---|---|
protected Map<ActiveMQDestination,Destination> |
AbstractRegion.destinations |
protected CopyOnWriteArrayList<Destination> |
AbstractSubscription.destinations |
Modifier and Type | Method and Description |
---|---|
Destination |
AbstractRegion.addDestination(ConnectionContext context,
ActiveMQDestination destination,
boolean createIfTemporary) |
Destination |
Region.addDestination(ConnectionContext context,
ActiveMQDestination destination,
boolean createIfTemporary)
Used to create a destination.
|
Destination |
RegionBroker.addDestination(ConnectionContext context,
ActiveMQDestination destination,
boolean createIfTemp) |
protected Destination |
AbstractRegion.createDestination(ConnectionContext context,
ActiveMQDestination destination) |
protected Destination |
AbstractTempRegion.createDestination(ConnectionContext context,
ActiveMQDestination destination) |
abstract Destination |
DestinationFactory.createDestination(ConnectionContext context,
ActiveMQDestination destination,
DestinationStatistics destinationStatistics)
Create destination implementation.
|
Destination |
DestinationFactoryImpl.createDestination(ConnectionContext context,
ActiveMQDestination destination,
DestinationStatistics destinationStatistics) |
Destination |
DestinationFilter.getNext() |
Destination |
NullMessageReference.getRegionDestination() |
Destination |
CompositeDestinationInterceptor.intercept(Destination destination) |
Destination |
DestinationInterceptor.intercept(Destination destination) |
protected Destination |
AbstractRegion.lookup(ConnectionContext context,
ActiveMQDestination destination,
boolean createTemporary) |
Modifier and Type | Method and Description |
---|---|
Map<ActiveMQDestination,Destination> |
AbstractRegion.getDestinationMap() |
Map<ActiveMQDestination,Destination> |
Region.getDestinationMap()
Returns a reference to the concurrent hash map that holds known destinations, do not modify
|
Map<ActiveMQDestination,Destination> |
RegionBroker.getDestinationMap() |
Map<ActiveMQDestination,Destination> |
RegionBroker.getDestinationMap(ActiveMQDestination destination) |
Set<Destination> |
AbstractRegion.getDestinations(ActiveMQDestination destination)
Provide an exact or wildcard lookup of destinations in the region
|
Set<Destination> |
Region.getDestinations(ActiveMQDestination destination)
Provide an exact or wildcard lookup of destinations in the region
|
Set<Destination> |
RegionBroker.getDestinations(ActiveMQDestination destination) |
Modifier and Type | Method and Description |
---|---|
void |
DurableTopicSubscription.add(ConnectionContext context,
Destination destination) |
void |
PrefetchSubscription.add(ConnectionContext context,
Destination destination) |
void |
Subscription.add(ConnectionContext context,
Destination destination)
The subscription will be receiving messages from the destination.
|
void |
AbstractSubscription.add(ConnectionContext context,
Destination destination) |
void |
AbstractSubscription.addDestination(Destination destination)
Add a destination
|
protected List<Subscription> |
AbstractRegion.addSubscriptionsForDestination(ConnectionContext context,
Destination dest) |
protected List<Subscription> |
TopicRegion.addSubscriptionsForDestination(ConnectionContext context,
Destination dest) |
protected void |
AbstractRegion.dispose(ConnectionContext context,
Destination dest) |
protected void |
AbstractTempRegion.dispose(ConnectionContext context,
Destination dest) |
Destination |
CompositeDestinationInterceptor.intercept(Destination destination) |
Destination |
DestinationInterceptor.intercept(Destination destination) |
List<MessageReference> |
QueueBrowserSubscription.remove(ConnectionContext context,
Destination destination) |
List<MessageReference> |
PrefetchSubscription.remove(ConnectionContext context,
Destination destination) |
List<MessageReference> |
Subscription.remove(ConnectionContext context,
Destination destination)
The subscription will be no longer be receiving messages from the destination.
|
List<MessageReference> |
AbstractSubscription.remove(ConnectionContext context,
Destination destination) |
List<MessageReference> |
PrefetchSubscription.remove(ConnectionContext context,
Destination destination,
List<MessageReference> dispatched) |
void |
CompositeDestinationInterceptor.remove(Destination destination) |
void |
DestinationInterceptor.remove(Destination destination) |
abstract void |
DestinationFactory.removeDestination(Destination dest) |
void |
DestinationFactoryImpl.removeDestination(Destination dest) |
void |
AbstractSubscription.removeDestination(Destination destination)
Remove a destination
|
Constructor and Description |
---|
DestinationFilter(Destination next) |
Modifier and Type | Field and Description |
---|---|
protected Destination |
AbstractStoreCursor.regionDestination |
Modifier and Type | Method and Description |
---|---|
void |
StoreDurableSubscriberCursor.add(ConnectionContext context,
Destination destination)
Add a destination
|
void |
PendingMessageCursor.add(ConnectionContext context,
Destination destination)
Add a destination
|
void |
AbstractPendingMessageCursor.add(ConnectionContext context,
Destination destination) |
boolean |
StoreDurableSubscriberCursor.isEmpty(Destination destination) |
boolean |
PendingMessageCursor.isEmpty(Destination destination)
check if a Destination is Empty for this cursor
|
boolean |
AbstractPendingMessageCursor.isEmpty(Destination destination) |
List<MessageReference> |
StoreDurableSubscriberCursor.remove(ConnectionContext context,
Destination destination)
remove a destination
|
List<MessageReference> |
PendingMessageCursor.remove(ConnectionContext context,
Destination destination)
remove a destination
|
List<MessageReference> |
VMPendingMessageCursor.remove(ConnectionContext context,
Destination destination) |
List<MessageReference> |
AbstractPendingMessageCursor.remove(ConnectionContext context,
Destination destination) |
Constructor and Description |
---|
AbstractStoreCursor(Destination destination) |
Modifier and Type | Method and Description |
---|---|
void |
SimpleMessageGroupMap.setDestination(Destination destination) |
void |
CachedMessageGroupMap.setDestination(Destination destination) |
void |
MessageGroupHashBucket.setDestination(Destination destination) |
void |
MessageGroupMap.setDestination(Destination destination) |
Modifier and Type | Method and Description |
---|---|
void |
AbortSlowAckConsumerStrategy.addDestination(Destination destination) |
void |
SlowConsumerStrategy.addDestination(Destination destination)
For Strategies that need to examine assigned destination for slow consumers
periodically the destination is assigned here.
|
void |
AbortSlowConsumerStrategy.addDestination(Destination destination) |
protected void |
QueryBasedSubscriptionRecoveryPolicy.dispatchInitialMessage(javax.jms.Message message,
Destination regionDestination,
ConnectionContext context,
SubscriptionRecovery sub) |
Modifier and Type | Class and Description |
---|---|
class |
CompositeDestinationFilter
Represents a composite
Destination where send()s are replicated to
each Destination instance. |
class |
MappedQueueFilter
Creates a mapped Queue that can recover messages from subscription recovery
policy of its Virtual Topic.
|
class |
SelectorAwareVirtualTopicInterceptor |
class |
VirtualTopicInterceptor
A Destination which implements Virtual Topic
|
Modifier and Type | Method and Description |
---|---|
protected Destination |
VirtualDestinationInterceptor.createCompositeDestination(Destination destination,
List<Destination> destinations) |
protected Destination |
MirroredQueue.getMirrorDestination(Destination destination) |
Destination |
VirtualDestinationInterceptor.intercept(Destination destination) |
Destination |
VirtualDestination.intercept(Destination destination)
Creates a virtual destination from the physical destination
|
Destination |
CompositeDestination.intercept(Destination destination) |
Destination |
MirroredQueue.intercept(Destination destination) |
Destination |
VirtualTopic.intercept(Destination destination) |
Destination |
CompositeTopic.interceptMappedDestination(Destination destination) |
Destination |
CompositeQueue.interceptMappedDestination(Destination destination) |
Destination |
VirtualDestination.interceptMappedDestination(Destination destination)
Creates a mapped destination
|
Destination |
VirtualTopic.interceptMappedDestination(Destination destination) |
Modifier and Type | Method and Description |
---|---|
protected Destination |
VirtualDestinationInterceptor.createCompositeDestination(Destination destination,
List<Destination> destinations) |
protected Destination |
MirroredQueue.getMirrorDestination(Destination destination) |
Destination |
VirtualDestinationInterceptor.intercept(Destination destination) |
Destination |
VirtualDestination.intercept(Destination destination)
Creates a virtual destination from the physical destination
|
Destination |
CompositeDestination.intercept(Destination destination) |
Destination |
MirroredQueue.intercept(Destination destination) |
Destination |
VirtualTopic.intercept(Destination destination) |
Destination |
CompositeTopic.interceptMappedDestination(Destination destination) |
Destination |
CompositeQueue.interceptMappedDestination(Destination destination) |
Destination |
VirtualDestination.interceptMappedDestination(Destination destination)
Creates a mapped destination
|
Destination |
VirtualTopic.interceptMappedDestination(Destination destination) |
void |
VirtualDestinationInterceptor.remove(Destination destination) |
void |
CompositeDestination.remove(Destination destination) |
void |
MirroredQueue.remove(Destination destination) |
void |
VirtualTopic.remove(Destination destination) |
protected boolean |
SelectorAwareVirtualTopicInterceptor.shouldDispatch(Broker broker,
Message message,
Destination dest)
Respect the selectors of the subscriptions to ensure only matched messages are dispatched to
the virtual queues, hence there is no build up of unmatched messages on these destinations
|
protected boolean |
VirtualTopicInterceptor.shouldDispatch(Broker broker,
Message message,
Destination dest) |
Modifier and Type | Method and Description |
---|---|
protected Destination |
VirtualDestinationInterceptor.createCompositeDestination(Destination destination,
List<Destination> destinations) |
Constructor and Description |
---|
CompositeDestinationFilter(Destination next,
Collection forwardDestinations,
boolean forwardOnly,
boolean concurrentSend) |
MappedQueueFilter(ActiveMQDestination virtualDestination,
Destination destination) |
SelectorAwareVirtualTopicInterceptor(Destination next,
VirtualTopic virtualTopic) |
VirtualTopicInterceptor(Destination next,
VirtualTopic virtualTopic) |
Modifier and Type | Method and Description |
---|---|
Destination |
DestinationsPlugin.addDestination(ConnectionContext context,
ActiveMQDestination destination,
boolean createIfTemporary) |
Destination |
DestinationPathSeparatorBroker.addDestination(ConnectionContext context,
ActiveMQDestination destination,
boolean createIfTemporary) |
Destination |
LoggingBrokerPlugin.addDestination(ConnectionContext context,
ActiveMQDestination destination,
boolean create) |
Modifier and Type | Method and Description |
---|---|
void |
LoggingBrokerPlugin.isFull(ConnectionContext context,
Destination destination,
Usage usage) |
void |
LoggingBrokerPlugin.slowConsumer(ConnectionContext context,
Destination destination,
Subscription subs) |
Modifier and Type | Method and Description |
---|---|
Destination |
DestinationDotFileInterceptor.addDestination(ConnectionContext context,
ActiveMQDestination destination,
boolean create) |
Modifier and Type | Class and Description |
---|---|
class |
AuthorizationDestinationFilter
Authorizes addSubscription calls.
|
Modifier and Type | Method and Description |
---|---|
Destination |
AuthorizationBroker.addDestination(ConnectionContext context,
ActiveMQDestination destination,
boolean create) |
Destination |
AuthorizationDestinationInterceptor.intercept(Destination destination) |
Modifier and Type | Method and Description |
---|---|
Destination |
AuthorizationDestinationInterceptor.intercept(Destination destination) |
void |
AuthorizationDestinationInterceptor.remove(Destination destination) |
Constructor and Description |
---|
AuthorizationDestinationFilter(Destination destination,
AuthorizationBroker broker) |
Modifier and Type | Method and Description |
---|---|
Destination |
AuthorizationFilter.addDestination(ConnectionContext context,
ActiveMQDestination destination,
boolean create) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
MessageDatabase.matchType(Destination destination,
KahaDestination.DestinationType type)
Determine whether this Destination matches the DestinationType
|
Copyright © 2005–2017 The Apache Software Foundation. All rights reserved.