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.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.command |
Command objects used via the Command Pattern to communicate among nodes
|
org.apache.activemq.security |
Plugable Security Adapter framework along with default implementations such as the JAAS implementation.
|
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 |
EmptyBroker.addDestination(ConnectionContext context,
ActiveMQDestination destination,
boolean flag) |
Destination |
BrokerFilter.addDestination(ConnectionContext context,
ActiveMQDestination destination,
boolean createIfTemporary) |
Destination |
MutableBrokerFilter.addDestination(ConnectionContext context,
ActiveMQDestination destination,
boolean createIfTemporary) |
Destination |
BrokerBroadcaster.addDestination(ConnectionContext context,
ActiveMQDestination destination,
boolean createIfTemporary) |
Destination |
ErrorBroker.addDestination(ConnectionContext context,
ActiveMQDestination destination,
boolean flag) |
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 |
---|---|
Map<ActiveMQDestination,Destination> |
EmptyBroker.getDestinationMap() |
Map<ActiveMQDestination,Destination> |
BrokerFilter.getDestinationMap() |
Map<ActiveMQDestination,Destination> |
MutableBrokerFilter.getDestinationMap() |
Map<ActiveMQDestination,Destination> |
ErrorBroker.getDestinationMap() |
Set<Destination> |
BrokerFilter.getDestinations(ActiveMQDestination destination) |
Modifier and Type | Method and Description |
---|---|
void |
EmptyBroker.isFull(ConnectionContext context,
Destination destination,
Usage usage) |
void |
BrokerFilter.isFull(ConnectionContext context,
Destination destination,
Usage usage) |
void |
MutableBrokerFilter.isFull(ConnectionContext context,
Destination destination,
Usage usage) |
void |
Broker.isFull(ConnectionContext context,
Destination destination,
Usage usage)
Called when a Usage reaches a limit
|
void |
ErrorBroker.isFull(ConnectionContext context,
Destination destination,
Usage usage) |
void |
ProducerBrokerExchange.setRegionDestination(Destination regionDestination) |
void |
ConsumerBrokerExchange.setRegionDestination(Destination regionDestination) |
void |
EmptyBroker.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 |
Broker.slowConsumer(ConnectionContext context,
Destination destination,
Subscription subs)
Called when there is a slow consumer
|
void |
ErrorBroker.slowConsumer(ConnectionContext context,
Destination destination,
Subscription subs) |
Modifier and Type | Field and Description |
---|---|
protected Destination |
DestinationView.destination |
Modifier and Type | Method and Description |
---|---|
protected Destination |
ManagedQueueRegion.createDestination(ConnectionContext context,
ActiveMQDestination destination) |
protected Destination |
ManagedTempTopicRegion.createDestination(ConnectionContext context,
ActiveMQDestination destination) |
protected Destination |
ManagedTopicRegion.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 CopyOnWriteArrayList<Destination> |
AbstractSubscription.destinations |
protected Map<ActiveMQDestination,Destination> |
AbstractRegion.destinations |
Modifier and Type | Method and Description |
---|---|
Destination |
Region.addDestination(ConnectionContext context,
ActiveMQDestination destination,
boolean createIfTemporary)
Used to create a destination.
|
Destination |
RegionBroker.addDestination(ConnectionContext context,
ActiveMQDestination destination,
boolean createIfTemp) |
Destination |
AbstractRegion.addDestination(ConnectionContext context,
ActiveMQDestination destination,
boolean createIfTemporary) |
protected Destination |
AbstractRegion.createDestination(ConnectionContext context,
ActiveMQDestination destination) |
protected Destination |
AbstractTempRegion.createDestination(ConnectionContext context,
ActiveMQDestination destination) |
Destination |
DestinationFactoryImpl.createDestination(ConnectionContext context,
ActiveMQDestination destination,
DestinationStatistics destinationStatistics) |
abstract Destination |
DestinationFactory.createDestination(ConnectionContext context,
ActiveMQDestination destination,
DestinationStatistics destinationStatistics)
Create destination implementation.
|
protected Destination |
TempQueueRegion.doCreateDestination(ConnectionContext context,
ActiveMQDestination destination) |
protected Destination |
TempTopicRegion.doCreateDestination(ConnectionContext context,
ActiveMQDestination destination) |
protected abstract Destination |
AbstractTempRegion.doCreateDestination(ConnectionContext context,
ActiveMQDestination destination) |
Destination |
IndirectMessageReference.getRegionDestination() |
Destination |
MessageReference.getRegionDestination() |
Destination |
DestinationInterceptor.intercept(Destination destination) |
Destination |
CompositeDestinationInterceptor.intercept(Destination destination) |
protected Destination |
AbstractRegion.lookup(ConnectionContext context,
ActiveMQDestination destination,
boolean createTemporary) |
Modifier and Type | Method and Description |
---|---|
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> |
AbstractRegion.getDestinationMap() |
Set<Destination> |
Region.getDestinations(ActiveMQDestination destination)
Provide an exact or wildcard lookup of destinations in the region
|
Set<Destination> |
RegionBroker.getDestinations(ActiveMQDestination destination) |
Set<Destination> |
AbstractRegion.getDestinations(ActiveMQDestination destination)
Provide an exact or wildcard lookup of destinations in the region
|
Modifier and Type | Method and Description |
---|---|
void |
PrefetchSubscription.add(ConnectionContext context,
Destination destination) |
void |
AbstractSubscription.add(ConnectionContext context,
Destination destination) |
void |
DurableTopicSubscription.add(ConnectionContext context,
Destination destination) |
void |
Subscription.add(ConnectionContext context,
Destination destination)
The subscription will be receiving messages from the destination.
|
void |
AbstractSubscription.addDestination(Destination destination)
Add a destination
|
protected List<Subscription> |
TopicRegion.addSubscriptionsForDestination(ConnectionContext context,
Destination dest) |
protected List<Subscription> |
AbstractRegion.addSubscriptionsForDestination(ConnectionContext context,
Destination dest) |
protected void |
AbstractRegion.dispose(ConnectionContext context,
Destination dest) |
protected void |
AbstractTempRegion.dispose(ConnectionContext context,
Destination dest) |
Destination |
DestinationInterceptor.intercept(Destination destination) |
Destination |
CompositeDestinationInterceptor.intercept(Destination destination) |
List<MessageReference> |
PrefetchSubscription.remove(ConnectionContext context,
Destination destination) |
List<MessageReference> |
AbstractSubscription.remove(ConnectionContext context,
Destination destination) |
List<MessageReference> |
QueueBrowserSubscription.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.
|
void |
DestinationInterceptor.remove(Destination destination) |
void |
CompositeDestinationInterceptor.remove(Destination destination) |
void |
AbstractSubscription.removeDestination(Destination destination)
Remove a destination
|
void |
DestinationFactoryImpl.removeDestination(Destination dest) |
abstract void |
DestinationFactory.removeDestination(Destination dest) |
Constructor and Description |
---|
DestinationFilter(Destination next) |
Modifier and Type | Field and Description |
---|---|
protected Destination |
AbstractStoreCursor.regionDestination |
Modifier and Type | Method and Description |
---|---|
void |
AbstractPendingMessageCursor.add(ConnectionContext context,
Destination destination) |
void |
PendingMessageCursor.add(ConnectionContext context,
Destination destination)
Add a destination
|
void |
StoreDurableSubscriberCursor.add(ConnectionContext context,
Destination destination)
Add a destination
|
boolean |
AbstractPendingMessageCursor.isEmpty(Destination destination) |
boolean |
PendingMessageCursor.isEmpty(Destination destination)
check if a Destination is Empty for this cursor
|
boolean |
StoreDurableSubscriberCursor.isEmpty(Destination destination) |
List<MessageReference> |
AbstractPendingMessageCursor.remove(ConnectionContext context,
Destination destination) |
List<MessageReference> |
PendingMessageCursor.remove(ConnectionContext context,
Destination destination)
remove a destination
|
List<MessageReference> |
VMPendingMessageCursor.remove(ConnectionContext context,
Destination destination) |
List<MessageReference> |
StoreDurableSubscriberCursor.remove(ConnectionContext context,
Destination destination)
remove a destination
|
Constructor and Description |
---|
AbstractStoreCursor(Destination destination) |
Modifier and Type | Method and Description |
---|---|
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 |
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 |
VirtualTopic.intercept(Destination destination) |
Destination |
MirroredQueue.intercept(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) |
Modifier and Type | Method and Description |
---|---|
protected Destination |
VirtualDestinationInterceptor.createCompositeDestination(Destination destination,
List<Destination> destinations) |
protected Destination |
MirroredQueue.getMirrorDestination(Destination destination) |
Destination |
VirtualTopic.intercept(Destination destination) |
Destination |
MirroredQueue.intercept(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) |
void |
VirtualTopic.remove(Destination destination) |
void |
MirroredQueue.remove(Destination destination) |
void |
VirtualDestinationInterceptor.remove(Destination destination) |
void |
CompositeDestination.remove(Destination destination) |
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 copyMessage) |
SelectorAwareVirtualTopicInterceptor(Destination next,
String prefix,
String postfix,
boolean local) |
VirtualTopicInterceptor(Destination next,
String prefix,
String postfix,
boolean local) |
Modifier and Type | Method and Description |
---|---|
Destination |
LoggingBrokerPlugin.addDestination(ConnectionContext context,
ActiveMQDestination destination,
boolean create) |
Destination |
DestinationPathSeparatorBroker.addDestination(ConnectionContext context,
ActiveMQDestination destination,
boolean createIfTemporary) |
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 | Method and Description |
---|---|
Destination |
Message.getRegionDestination() |
Modifier and Type | Method and Description |
---|---|
void |
Message.setRegionDestination(Destination destination) |
Modifier and Type | Method and Description |
---|---|
Destination |
AuthorizationBroker.addDestination(ConnectionContext context,
ActiveMQDestination destination,
boolean create) |
Copyright © 2005–2014. All rights reserved.