Package | Description |
---|---|
org.apache.activemq.broker |
The core classes for the ActiveMQ Message Broker and its connectors.
|
org.apache.activemq.broker.inteceptor |
MessageInteceptor malarky
|
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 |
The Message Scheduler for delayed (or scheduled) message delivery
|
org.apache.activemq.broker.util |
Some utility Broker Plugins
|
org.apache.activemq.broker.view |
Broker Plugins for visualising the current system
|
org.apache.activemq.camel.camelplugin | |
org.apache.activemq.camel.component.broker | |
org.apache.activemq.partition | |
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 |
---|---|
ProducerBrokerExchange |
ProducerBrokerExchange.copy() |
ProducerBrokerExchange |
BrokerService.getProducerBrokerExchange(ProducerInfo producerInfo) |
ProducerBrokerExchange |
TransportConnection.getProducerBrokerExchangeIfExists(ProducerInfo producerInfo) |
Modifier and Type | Method and Description |
---|---|
void |
UserIDBroker.send(ProducerBrokerExchange producerExchange,
Message messageSend) |
void |
TransactionBroker.send(ProducerBrokerExchange producerExchange,
Message message) |
void |
MutableBrokerFilter.send(ProducerBrokerExchange producerExchange,
Message messageSend) |
void |
ErrorBroker.send(ProducerBrokerExchange producerExchange,
Message message) |
void |
EmptyBroker.send(ProducerBrokerExchange producerExchange,
Message message) |
void |
CompositeDestinationBroker.send(ProducerBrokerExchange producerExchange,
Message message) |
void |
BrokerFilter.send(ProducerBrokerExchange producerExchange,
Message messageSend) |
void |
BrokerBroadcaster.send(ProducerBrokerExchange producerExchange,
Message messageSend) |
Modifier and Type | Method and Description |
---|---|
void |
MessageInterceptorRegistry.injectMessage(ProducerBrokerExchange producerExchange,
Message messageSend)
Re-inject into the Broker chain
|
void |
MessageInterceptor.intercept(ProducerBrokerExchange producerExchange,
Message message) |
Modifier and Type | Method and Description |
---|---|
void |
ManagedRegionBroker.send(ProducerBrokerExchange exchange,
Message message) |
Modifier and Type | Method and Description |
---|---|
void |
Topic.send(ProducerBrokerExchange producerExchange,
Message message) |
void |
RegionBroker.send(ProducerBrokerExchange producerExchange,
Message message) |
void |
Region.send(ProducerBrokerExchange producerExchange,
Message message)
Send a message to the broker to using the specified destination.
|
void |
Queue.send(ProducerBrokerExchange producerExchange,
Message message) |
void |
DestinationFilter.send(ProducerBrokerExchange context,
Message messageSend) |
void |
Destination.send(ProducerBrokerExchange producerExchange,
Message messageSend) |
void |
AbstractRegion.send(ProducerBrokerExchange producerExchange,
Message messageSend) |
protected void |
DestinationFilter.send(ProducerBrokerExchange context,
Message message,
ActiveMQDestination destination)
Sends a message to the given destination which may be a wildcard
|
protected void |
BaseDestination.waitForSpace(ConnectionContext context,
ProducerBrokerExchange producerBrokerExchange,
Usage<?> usage,
int highWaterMark,
String warning) |
protected void |
BaseDestination.waitForSpace(ConnectionContext context,
ProducerBrokerExchange producerBrokerExchange,
Usage<?> usage,
String warning) |
Modifier and Type | Method and Description |
---|---|
void |
VirtualTopicInterceptor.send(ProducerBrokerExchange context,
Message message) |
void |
CompositeDestinationFilter.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 |
UDPTraceBrokerPlugin.send(ProducerBrokerExchange producerExchange,
Message messageSend) |
void |
TimeStampingBrokerPlugin.send(ProducerBrokerExchange producerExchange,
Message message) |
void |
LoggingBrokerPlugin.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 |
CamelRoutesBroker.send(ProducerBrokerExchange producerExchange,
Message message)
Overide methods to pause the broker whilst camel routes are loaded
|
Modifier and Type | Method and Description |
---|---|
protected void |
BrokerEndpoint.inject(ProducerBrokerExchange producerBrokerExchange,
Message message) |
void |
BrokerConsumer.intercept(ProducerBrokerExchange producerExchange,
Message message) |
Modifier and Type | Method and Description |
---|---|
void |
PartitionBroker.send(ProducerBrokerExchange producerExchange,
Message messageSend) |
Modifier and Type | Method and Description |
---|---|
void |
StatisticsBroker.send(ProducerBrokerExchange producerExchange,
Message messageSend)
Sets the persistence mode
|
void |
ForcePersistencyModeBroker.send(ProducerBrokerExchange producerExchange,
Message messageSend)
Sets the persistence mode
|
Modifier and Type | Method and Description |
---|---|
void |
AuthorizationBroker.send(ProducerBrokerExchange producerExchange,
Message messageSend) |
Modifier and Type | Method and Description |
---|---|
void |
AuthorizationFilter.send(ProducerBrokerExchange exchange,
Message message) |
Copyright © 2005–2015 FuseSource, Corp.. All rights reserved.