Package | Description |
---|---|
org.apache.activemq |
The core JMS client API implementation classes.
|
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.network |
Support for federated networks of brokers.
|
org.apache.activemq.state | |
org.apache.activemq.transport |
The core Transport abstraction and support classes
|
org.apache.activemq.transport.discovery |
Discovery mechanism to discover brokers and clients.
|
org.apache.activemq.transport.failover |
Fail-Over Transport which will automatically reconnect to a failed transport and choose one of a list of possible transport implementations to use.
|
org.apache.activemq.transport.fanout |
Fan-out Transport implementation which ensures that a message is sent to multiple destinations such as to ensure multiple brokers received a message for non-durable topic delivery to improve redundancy
|
org.apache.activemq.transport.mock |
A mock implementation of the Transport layer useful for testing
|
org.apache.activemq.transport.multicast |
A Multicast based Transport implementation.
|
org.apache.activemq.transport.nio | |
org.apache.activemq.transport.peer |
Peer based Transport implementation which does not require central servers to connect to
|
org.apache.activemq.transport.reliable |
The Reliable transport deals with out of order commands as well as dealing with checking for missed commands and possibly re-requesting the replay of dropped commands.
|
org.apache.activemq.transport.stomp |
An implementation of the Stomp protocol which is a simple wire protocol for writing clients for ActiveMQ in different
languages like Ruby, Python, PHP, C etc.
|
org.apache.activemq.transport.tcp |
TCP/IP based Transport implementation.
|
org.apache.activemq.transport.udp |
UDP based Transport implementation.
|
org.apache.activemq.transport.vm |
In-JVM based Transport implementation.
|
Modifier and Type | Method and Description |
---|---|
protected Transport |
ActiveMQConnectionFactory.createTransport()
Creates a Transport based on this object's connection settings.
|
protected Transport |
ActiveMQSslConnectionFactory.createTransport()
Overriding to make special considerations for SSL connections.
|
Transport |
ActiveMQConnection.getTransport() |
Transport |
ActiveMQConnection.getTransportChannel() |
Modifier and Type | Method and Description |
---|---|
protected ActiveMQConnection |
ActiveMQConnectionFactory.createActiveMQConnection(Transport transport,
JMSStatsImpl stats) |
protected ActiveMQConnection |
ActiveMQXAConnectionFactory.createActiveMQConnection(Transport transport,
JMSStatsImpl stats) |
Constructor and Description |
---|
ActiveMQConnection(Transport transport,
IdGenerator clientIdGenerator,
IdGenerator connectionIdGenerator,
JMSStatsImpl factoryStats)
Construct an
ActiveMQConnection |
ActiveMQXAConnection(Transport transport,
IdGenerator clientIdGenerator,
IdGenerator connectionIdGenerator,
JMSStatsImpl factoryStats) |
Modifier and Type | Method and Description |
---|---|
protected Connection |
TransportConnector.createConnection(Transport transport) |
Constructor and Description |
---|
TransportConnection(TransportConnector connector,
Transport transport,
Broker broker,
TaskRunnerFactory taskRunnerFactory) |
Constructor and Description |
---|
MasterBroker(MutableBrokerFilter parent,
Transport transport)
Constructor
|
Modifier and Type | Method and Description |
---|---|
protected Connection |
ManagedTransportConnector.createConnection(Transport transport) |
Constructor and Description |
---|
ManagedTransportConnection(TransportConnector connector,
Transport transport,
Broker broker,
TaskRunnerFactory factory,
ManagementContext context,
ObjectName connectorName) |
Modifier and Type | Field and Description |
---|---|
protected Transport |
DemandForwardingBridgeSupport.localBroker |
protected Transport |
DemandForwardingBridgeSupport.remoteBroker |
Modifier and Type | Method and Description |
---|---|
protected Transport |
NetworkConnector.createLocalTransport() |
Transport |
DemandForwardingBridgeSupport.getLocalBroker() |
Transport |
MulticastNetworkConnector.getLocalTransport() |
Transport |
DemandForwardingBridgeSupport.getRemoteBroker() |
Transport |
MulticastNetworkConnector.getRemoteTransport() |
Modifier and Type | Method and Description |
---|---|
static DemandForwardingBridge |
NetworkBridgeFactory.createBridge(NetworkBridgeConfiguration config,
Transport localTransport,
Transport remoteTransport)
Create a network bridge
|
static DemandForwardingBridge |
NetworkBridgeFactory.createBridge(NetworkBridgeConfiguration configuration,
Transport localTransport,
Transport remoteTransport,
NetworkBridgeListener listener)
create a network bridge
|
protected DemandForwardingBridgeSupport |
MulticastNetworkConnector.createBridge(Transport local,
Transport remote) |
protected NetworkBridge |
DiscoveryNetworkConnector.createBridge(Transport localTransport,
Transport remoteTransport,
DiscoveryEvent event) |
void |
MulticastNetworkConnector.setLocalTransport(Transport localTransport) |
void |
MulticastNetworkConnector.setRemoteTransport(Transport remoteTransport)
Sets the remote transport implementation
|
Constructor and Description |
---|
CompositeDemandForwardingBridge(NetworkBridgeConfiguration configuration,
Transport localBroker,
Transport remoteBroker) |
ConduitBridge(NetworkBridgeConfiguration configuration,
Transport localBroker,
Transport remoteBroker)
Constructor
|
DemandForwardingBridge(NetworkBridgeConfiguration configuration,
Transport localBroker,
Transport remoteBroker) |
DemandForwardingBridgeSupport(NetworkBridgeConfiguration configuration,
Transport localBroker,
Transport remoteBroker) |
DurableConduitBridge(NetworkBridgeConfiguration configuration,
Transport localBroker,
Transport remoteBroker)
Constructor
|
ForwardingBridge(Transport localBroker,
Transport remoteBroker) |
Modifier and Type | Method and Description |
---|---|
void |
ConnectionStateTracker.connectionInterruptProcessingComplete(Transport transport,
ConnectionId connectionId) |
void |
ConnectionStateTracker.restore(Transport transport) |
protected void |
ConnectionStateTracker.restoreConsumers(Transport transport,
SessionState sessionState) |
protected void |
ConnectionStateTracker.restoreProducers(Transport transport,
SessionState sessionState) |
protected void |
ConnectionStateTracker.restoreSessions(Transport transport,
ConnectionState connectionState) |
protected void |
ConnectionStateTracker.restoreTempDestinations(Transport transport,
ConnectionState connectionState) |
Modifier and Type | Interface and Description |
---|---|
interface |
CompositeTransport |
Modifier and Type | Class and Description |
---|---|
class |
AbstractInactivityMonitor
Used to make sure that commands are arriving periodically from the peer of
the transport.
|
class |
CommandJoiner
Joins together of partial commands which were split into individual chunks of
data.
|
class |
InactivityMonitor
Used to make sure that commands are arriving periodically from the peer of
the transport.
|
class |
MarshallingTransportFilter |
class |
MutexTransport
Thread safe Transport Filter that serializes calls to and from the Transport Stack.
|
class |
ResponseCorrelator
Adds the incrementing sequence number to commands along with performing the
corelation of responses to requests to create a blocking request-response
semantics.
|
class |
ThreadNameFilter
The thread name filter, modifies the name of the thread during the invocation to a transport.
|
class |
TransportFilter |
class |
TransportLogger
This TransportFilter implementation writes output to a log
as it intercepts commands / events before sending them to the
following layer in the Transport stack.
|
class |
TransportSupport
A useful base class for transport implementations.
|
class |
TransportThreadSupport
A useful base class for a transport implementation which has a background
reading thread.
|
class |
WireFormatNegotiator
Negotiates the wire format with a new connection
|
class |
WriteTimeoutFilter
This filter implements write timeouts for socket write operations.
|
Modifier and Type | Field and Description |
---|---|
protected Transport |
TransportFilter.next |
Modifier and Type | Method and Description |
---|---|
Transport |
TransportFactory.compositeConfigure(Transport transport,
WireFormat format,
Map options)
Similar to configure(...) but this avoid adding in the MutexTransport and
ResponseCorrelator transport layers so that the resulting transport can
more efficiently be used as part of a composite transport.
|
static Transport |
TransportFactory.compositeConnect(URI location)
Creates a slimmed down transport that is more efficient so that it can be
used by composite transports like reliable and HA.
|
static Transport |
TransportFactory.compositeConnect(URI location,
Executor ex)
Creates a slimmed down transport that is more efficient so that it can be
used by composite transports like reliable and HA.
|
Transport |
TransportFactory.configure(Transport transport,
WireFormat wf,
Map options)
Fully configures and adds all need transport filters so that the
transport can be used by the JMS client.
|
static Transport |
TransportFactory.connect(URI location)
Creates a normal transport.
|
static Transport |
TransportFactory.connect(URI location,
Executor ex)
Creates a normal transport.
|
protected Transport |
TransportFactory.createTransport(URI location,
WireFormat wf)
Factory method to create a new transport
|
Transport |
TransportFactory.doCompositeConnect(URI location) |
Transport |
TransportFactory.doCompositeConnect(URI location,
Executor ex) |
Transport |
TransportFactory.doConnect(URI location) |
Transport |
TransportFactory.doConnect(URI location,
Executor ex) |
Transport |
TransportFilter.getNext() |
Transport |
TransportFactory.serverConfigure(Transport transport,
WireFormat format,
HashMap options)
Fully configures and adds all need transport filters so that the
transport can be used by the ActiveMQ message broker.
|
Modifier and Type | Method and Description |
---|---|
Transport |
TransportFactory.compositeConfigure(Transport transport,
WireFormat format,
Map options)
Similar to configure(...) but this avoid adding in the MutexTransport and
ResponseCorrelator transport layers so that the resulting transport can
more efficiently be used as part of a composite transport.
|
Transport |
TransportFactory.configure(Transport transport,
WireFormat wf,
Map options)
Fully configures and adds all need transport filters so that the
transport can be used by the JMS client.
|
TransportLogger |
TransportLoggerFactory.createTransportLogger(Transport next)
Creates a TransportLogger object, that will be inserted in the Transport Stack.
|
TransportLogger |
TransportLoggerFactory.createTransportLogger(Transport next,
int id,
org.slf4j.Logger log,
String logWriterName,
boolean dynamicManagement,
boolean startLogging,
int jmxport)
Creates a TransportLogger object, that will be inserted in the Transport Stack.
|
TransportLogger |
TransportLoggerFactory.createTransportLogger(Transport next,
org.slf4j.Logger log)
Creates a TransportLogger object, that will be inserted in the Transport Stack.
|
TransportLogger |
TransportLoggerFactory.createTransportLogger(Transport next,
String logWriterName,
boolean useJmx,
boolean startLogging,
int jmxport)
Creates a TransportLogger object, that will be inserted in the Transport Stack.
|
void |
TransportAcceptListener.onAccept(Transport transport) |
Transport |
TransportFactory.serverConfigure(Transport transport,
WireFormat format,
HashMap options)
Fully configures and adds all need transport filters so that the
transport can be used by the ActiveMQ message broker.
|
Constructor and Description |
---|
AbstractInactivityMonitor(Transport next,
WireFormat wireFormat) |
CommandJoiner(Transport next,
OpenWireFormat wireFormat) |
InactivityMonitor(Transport next,
WireFormat wireFormat) |
MarshallingTransportFilter(Transport next,
WireFormat localWireFormat,
WireFormat remoteWireFormat) |
MutexTransport(Transport next) |
MutexTransport(Transport next,
boolean syncOnCommand) |
ResponseCorrelator(Transport next) |
ResponseCorrelator(Transport next,
IntSequenceGenerator sequenceGenerator) |
ThreadNameFilter(Transport next) |
TransportFilter(Transport next) |
TransportLogger(Transport next,
org.slf4j.Logger log,
boolean startLogging,
LogWriter logWriter) |
WireFormatNegotiator(Transport next,
OpenWireFormat wireFormat,
int minimumVersion)
Negotiator
|
WriteTimeoutFilter(Transport next) |
Modifier and Type | Class and Description |
---|---|
class |
DiscoveryTransport
A
ReliableTransportChannel which uses a DiscoveryAgent to
discover remote broker instances and dynamically connect to them. |
Modifier and Type | Method and Description |
---|---|
Transport |
DiscoveryTransportFactory.createTransport(URISupport.CompositeData compositeData) |
Modifier and Type | Class and Description |
---|---|
class |
FailoverTransport
A Transport that is made reliable by being able to fail over to another
transport when a transport failure is detected.
|
Modifier and Type | Method and Description |
---|---|
Transport |
FailoverTransportFactory.createTransport(URISupport.CompositeData compositData) |
Transport |
FailoverTransportFactory.doCompositeConnect(URI location) |
Transport |
FailoverTransportFactory.doConnect(URI location) |
Transport |
FailoverTransport.getConnectedTransport() |
Modifier and Type | Method and Description |
---|---|
void |
FailoverTransport.disposeTransport(Transport transport) |
protected void |
FailoverTransport.restoreTransport(Transport t) |
Modifier and Type | Class and Description |
---|---|
class |
FanoutTransport
A Transport that fans out a connection to multiple brokers.
|
Modifier and Type | Method and Description |
---|---|
Transport |
FanoutTransportFactory.createTransport(URI location) |
Transport |
FanoutTransportFactory.doCompositeConnect(URI location) |
Transport |
FanoutTransportFactory.doConnect(URI location) |
Modifier and Type | Class and Description |
---|---|
class |
MockTransport |
Modifier and Type | Field and Description |
---|---|
protected Transport |
MockTransport.next |
Modifier and Type | Method and Description |
---|---|
Transport |
MockTransportFactory.createTransport(URISupport.CompositeData compositData) |
Transport |
MockTransportFactory.doCompositeConnect(URI location) |
Transport |
MockTransportFactory.doConnect(URI location) |
Transport |
MockTransport.getNext() |
Modifier and Type | Method and Description |
---|---|
void |
MockTransport.setNext(Transport next) |
Constructor and Description |
---|
MockTransport(Transport next) |
Modifier and Type | Class and Description |
---|---|
class |
MulticastTransport
A multicast based transport.
|
Modifier and Type | Method and Description |
---|---|
protected Transport |
MulticastTransportFactory.createTransport(URI location,
WireFormat wf) |
Modifier and Type | Class and Description |
---|---|
class |
NIOSSLTransport |
class |
NIOTransport
An implementation of the
Transport interface using raw tcp/ip |
Modifier and Type | Method and Description |
---|---|
Transport |
NIOSSLTransportFactory.compositeConfigure(Transport transport,
WireFormat format,
Map options)
Overriding to allow for proper configuration through reflection but delegate to get common
configuration
|
protected Transport |
NIOSSLTransportFactory.createTransport(URI location,
WireFormat wf)
Overriding to use SslTransports.
|
Modifier and Type | Method and Description |
---|---|
Transport |
NIOSSLTransportFactory.compositeConfigure(Transport transport,
WireFormat format,
Map options)
Overriding to allow for proper configuration through reflection but delegate to get common
configuration
|
Modifier and Type | Method and Description |
---|---|
Transport |
PeerTransportFactory.doCompositeConnect(URI location) |
Transport |
PeerTransportFactory.doConnect(URI location) |
Modifier and Type | Class and Description |
---|---|
class |
ReliableTransport
This interceptor deals with out of order commands together with being able to
handle dropped commands and the re-requesting dropped commands.
|
Constructor and Description |
---|
ReliableTransport(Transport next,
ReplayStrategy replayStrategy) |
ReliableTransport(Transport next,
UdpTransport udpTransport) |
Modifier and Type | Class and Description |
---|---|
class |
StompInactivityMonitor
Used to make sure that commands are arriving periodically from the peer of
the transport.
|
class |
StompNIOSSLTransport |
class |
StompNIOTransport
An implementation of the
Transport interface for using Stomp over NIO |
class |
StompTransportFilter
The StompTransportFilter normally sits on top of a TcpTransport that has been
configured with the StompWireFormat and is used to convert STOMP commands to
ActiveMQ commands.
|
Modifier and Type | Method and Description |
---|---|
Transport |
StompTransportFactory.compositeConfigure(Transport transport,
WireFormat format,
Map options) |
Transport |
StompNIOTransportFactory.compositeConfigure(Transport transport,
WireFormat format,
Map options) |
Transport |
StompSslTransportFactory.compositeConfigure(Transport transport,
WireFormat format,
Map options) |
protected Transport |
StompTransportFactory.createInactivityMonitor(Transport transport,
WireFormat format) |
Transport |
StompTransportFactory.serverConfigure(Transport transport,
WireFormat format,
HashMap options) |
Transport |
StompNIOTransportFactory.serverConfigure(Transport transport,
WireFormat format,
HashMap options) |
Transport |
StompSslTransportFactory.serverConfigure(Transport transport,
WireFormat format,
HashMap options) |
Modifier and Type | Method and Description |
---|---|
Transport |
StompTransportFactory.compositeConfigure(Transport transport,
WireFormat format,
Map options) |
Transport |
StompNIOTransportFactory.compositeConfigure(Transport transport,
WireFormat format,
Map options) |
Transport |
StompSslTransportFactory.compositeConfigure(Transport transport,
WireFormat format,
Map options) |
protected Transport |
StompTransportFactory.createInactivityMonitor(Transport transport,
WireFormat format) |
Transport |
StompTransportFactory.serverConfigure(Transport transport,
WireFormat format,
HashMap options) |
Transport |
StompNIOTransportFactory.serverConfigure(Transport transport,
WireFormat format,
HashMap options) |
Transport |
StompSslTransportFactory.serverConfigure(Transport transport,
WireFormat format,
HashMap options) |
Constructor and Description |
---|
StompInactivityMonitor(Transport next,
WireFormat wireFormat) |
StompTransportFilter(Transport next,
WireFormat wireFormat,
BrokerContext brokerContext) |
Modifier and Type | Class and Description |
---|---|
class |
SslTransport
A Transport class that uses SSL and client-side certificate authentication.
|
class |
TcpTransport
An implementation of the
Transport interface using raw tcp/ip |
Modifier and Type | Method and Description |
---|---|
Transport |
SslTransportFactory.compositeConfigure(Transport transport,
WireFormat format,
Map options)
Overriding to allow for proper configuration through reflection but delegate to get common
configuration
|
Transport |
TcpTransportFactory.compositeConfigure(Transport transport,
WireFormat format,
Map options) |
protected Transport |
TcpTransportFactory.createInactivityMonitor(Transport transport,
WireFormat format) |
protected Transport |
TcpTransportServer.createTransport(Socket socket,
WireFormat format)
Allow derived classes to override the Transport implementation that this
transport server creates.
|
protected Transport |
SslTransportServer.createTransport(Socket socket,
WireFormat format)
Used to create Transports for this server.
|
protected Transport |
SslTransportFactory.createTransport(URI location,
WireFormat wf)
Overriding to use SslTransports.
|
protected Transport |
TcpTransportFactory.createTransport(URI location,
WireFormat wf) |
Modifier and Type | Method and Description |
---|---|
Transport |
SslTransportFactory.compositeConfigure(Transport transport,
WireFormat format,
Map options)
Overriding to allow for proper configuration through reflection but delegate to get common
configuration
|
Transport |
TcpTransportFactory.compositeConfigure(Transport transport,
WireFormat format,
Map options) |
protected Transport |
TcpTransportFactory.createInactivityMonitor(Transport transport,
WireFormat format) |
protected boolean |
TcpTransportFactory.isUseInactivityMonitor(Transport transport)
Returns true if the inactivity monitor should be used on the transport
|
Modifier and Type | Class and Description |
---|---|
class |
ResponseRedirectInterceptor |
class |
UdpTransport
An implementation of the
Transport interface using raw UDP |
Modifier and Type | Method and Description |
---|---|
Transport |
UdpTransportFactory.compositeConfigure(Transport transport,
WireFormat format,
Map options) |
Transport |
UdpTransportFactory.configure(Transport transport,
WireFormat format,
Map options) |
protected Transport |
UdpTransportFactory.configure(Transport transport,
WireFormat format,
Map options,
boolean acceptServer)
Configures the transport
|
protected Transport |
UdpTransportFactory.configureClientSideNegotiator(Transport transport,
WireFormat format,
UdpTransport udpTransport) |
protected Transport |
UdpTransportServer.configureTransport(Transport transport) |
protected Transport |
UdpTransportServer.createTransport(Command command,
DatagramEndpoint endpoint) |
protected Transport |
UdpTransportFactory.createTransport(int port,
WireFormat wf) |
protected Transport |
UdpTransportFactory.createTransport(URI location,
WireFormat wf) |
Modifier and Type | Method and Description |
---|---|
Transport |
UdpTransportFactory.compositeConfigure(Transport transport,
WireFormat format,
Map options) |
Transport |
UdpTransportFactory.configure(Transport transport,
WireFormat format,
Map options) |
protected Transport |
UdpTransportFactory.configure(Transport transport,
WireFormat format,
Map options,
boolean acceptServer)
Configures the transport
|
protected Transport |
UdpTransportFactory.configureClientSideNegotiator(Transport transport,
WireFormat format,
UdpTransport udpTransport) |
protected Transport |
UdpTransportServer.configureTransport(Transport transport) |
Constructor and Description |
---|
ResponseRedirectInterceptor(Transport next,
UdpTransport transport) |
UdpTransportServer(URI connectURI,
UdpTransport serverTransport,
Transport configuredTransport,
ReplayStrategy replayStrategy) |
Modifier and Type | Class and Description |
---|---|
class |
VMTransport
A Transport implementation that uses direct method invocations.
|
Modifier and Type | Method and Description |
---|---|
static Transport |
VMTransportServer.configure(Transport transport)
Configure transport
|
Transport |
VMTransportFactory.doCompositeConnect(URI location) |
Transport |
VMTransportFactory.doConnect(URI location) |
Modifier and Type | Method and Description |
---|---|
static Transport |
VMTransportServer.configure(Transport transport)
Configure transport
|
Copyright © 2005–2015 The Apache Software Foundation. All rights reserved.