Package | Description |
---|---|
org.apache.activemq.broker |
The core classes for the ActiveMQ Message Broker and its connectors.
|
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.virtual |
Implementation classes for Virtual Destinations
|
org.apache.activemq.broker.scheduler | |
org.apache.activemq.broker.util |
Some utility Broker Plugins
|
org.apache.activemq.broker.view |
Broker Plugins for visualising the current system
|
org.apache.activemq.plugin | |
org.apache.activemq.security |
Plugable Security Adapter framework along with default implementations such as the JAAS implementation.
|
Modifier and Type | Method and Description |
---|---|
ProducerBrokerExchange |
ProducerBrokerExchange.copy() |
Modifier and Type | Method and Description |
---|---|
void |
BrokerBroadcaster.send(ProducerBrokerExchange producerExchange,
Message messageSend) |
void |
TransactionBroker.send(ProducerBrokerExchange producerExchange,
Message message) |
void |
CompositeDestinationBroker.send(ProducerBrokerExchange producerExchange,
Message message) |
void |
BrokerFilter.send(ProducerBrokerExchange producerExchange,
Message messageSend) |
void |
MutableBrokerFilter.send(ProducerBrokerExchange producerExchange,
Message messageSend) |
void |
ErrorBroker.send(ProducerBrokerExchange producerExchange,
Message message) |
void |
EmptyBroker.send(ProducerBrokerExchange producerExchange,
Message message) |
void |
UserIDBroker.send(ProducerBrokerExchange producerExchange,
Message messageSend) |
Modifier and Type | Method and Description |
---|---|
void |
MasterBroker.send(ProducerBrokerExchange producerExchange,
Message message) |
Modifier and Type | Method and Description |
---|---|
void |
ManagedRegionBroker.send(ProducerBrokerExchange exchange,
Message message) |
Modifier and Type | Method and Description |
---|---|
void |
Queue.send(ProducerBrokerExchange producerExchange,
Message message) |
void |
Topic.send(ProducerBrokerExchange producerExchange,
Message message) |
void |
RegionBroker.send(ProducerBrokerExchange producerExchange,
Message message) |
void |
Destination.send(ProducerBrokerExchange producerExchange,
Message messageSend) |
void |
AbstractRegion.send(ProducerBrokerExchange producerExchange,
Message messageSend) |
void |
Region.send(ProducerBrokerExchange producerExchange,
Message message)
Send a message to the broker to using the specified destination.
|
void |
DestinationFilter.send(ProducerBrokerExchange context,
Message messageSend) |
protected void |
DestinationFilter.send(ProducerBrokerExchange context,
Message message,
ActiveMQDestination destination)
Sends a message to the given destination which may be a wildcard
|
Modifier and Type | Method and Description |
---|---|
void |
CompositeDestinationFilter.send(ProducerBrokerExchange context,
Message message) |
void |
VirtualTopicInterceptor.send(ProducerBrokerExchange context,
Message message) |
protected void |
SelectorAwareVirtualTopicInterceptor.send(ProducerBrokerExchange context,
Message message,
ActiveMQDestination destination)
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
|
Modifier and Type | Method and Description |
---|---|
void |
SchedulerBroker.send(ProducerBrokerExchange producerExchange,
Message messageSend) |
Modifier and Type | Method and Description |
---|---|
void |
LoggingBrokerPlugin.send(ProducerBrokerExchange producerExchange,
Message messageSend) |
void |
TimeStampingBrokerPlugin.send(ProducerBrokerExchange producerExchange,
Message message) |
void |
UDPTraceBrokerPlugin.send(ProducerBrokerExchange producerExchange,
Message messageSend) |
void |
DestinationPathSeparatorBroker.send(ProducerBrokerExchange producerExchange,
Message messageSend) |
Modifier and Type | Method and Description |
---|---|
void |
ConnectionDotFileInterceptor.send(ProducerBrokerExchange producerExchange,
Message messageSend) |
Modifier and Type | Method and Description |
---|---|
void |
ForcePersistencyModeBroker.send(ProducerBrokerExchange producerExchange,
Message messageSend)
Sets the persistence mode
|
void |
StatisticsBroker.send(ProducerBrokerExchange producerExchange,
Message messageSend)
Sets the persistence mode
|
Modifier and Type | Method and Description |
---|---|
void |
AuthorizationBroker.send(ProducerBrokerExchange producerExchange,
Message messageSend) |
Copyright © 2005–2015. All rights reserved.