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.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() |
ProducerBrokerExchange |
BrokerService.getProducerBrokerExchange(ProducerInfo producerInfo) |
ProducerBrokerExchange |
TransportConnection.getProducerBrokerExchangeIfExists(ProducerInfo producerInfo) |
Modifier and Type | Method and Description |
---|---|
void |
MutableBrokerFilter.send(ProducerBrokerExchange producerExchange,
Message messageSend) |
void |
TransactionBroker.send(ProducerBrokerExchange producerExchange,
Message message) |
void |
BrokerBroadcaster.send(ProducerBrokerExchange producerExchange,
Message messageSend) |
void |
EmptyBroker.send(ProducerBrokerExchange producerExchange,
Message message) |
void |
ErrorBroker.send(ProducerBrokerExchange producerExchange,
Message message) |
void |
UserIDBroker.send(ProducerBrokerExchange producerExchange,
Message messageSend) |
void |
CompositeDestinationBroker.send(ProducerBrokerExchange producerExchange,
Message message) |
void |
BrokerFilter.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 |
Destination.send(ProducerBrokerExchange producerExchange,
Message messageSend) |
void |
RegionBroker.send(ProducerBrokerExchange producerExchange,
Message message) |
void |
AbstractRegion.send(ProducerBrokerExchange producerExchange,
Message messageSend) |
void |
DestinationFilter.send(ProducerBrokerExchange context,
Message messageSend) |
void |
Topic.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) |
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 |
CompositeDestinationFilter.send(ProducerBrokerExchange context,
Message message) |
void |
VirtualTopicInterceptor.send(ProducerBrokerExchange context,
Message message) |
protected void |
VirtualTopicInterceptor.send(ProducerBrokerExchange context,
Message message,
ActiveMQDestination destination) |
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 |
UDPTraceBrokerPlugin.send(ProducerBrokerExchange producerExchange,
Message messageSend) |
void |
DestinationPathSeparatorBroker.send(ProducerBrokerExchange producerExchange,
Message messageSend) |
void |
TimeStampingBrokerPlugin.send(ProducerBrokerExchange producerExchange,
Message message) |
Modifier and Type | Method and Description |
---|---|
void |
ConnectionDotFileInterceptor.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) |
Copyright © 2005–2024 The Apache Software Foundation. All rights reserved.