Package | Description |
---|---|
org.apache.activemq |
The core JMS client API implementation classes.
|
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.mqtt |
A Broker side implementation of the MQTT 3.1 protocol - see http://mqtt.org/
|
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.udp |
UDP based Transport implementation.
|
org.apache.activemq.transport.vm |
In-JVM based Transport implementation.
|
Modifier and Type | Class and Description |
---|---|
class |
ActiveMQConnection |
class |
ActiveMQXAConnection
The XAConnection interface extends the capability of Connection by providing
an XASession (optional).
|
Modifier and Type | Method and Description |
---|---|
TransportListener |
ActiveMQConnectionFactory.getTransportListener() |
Modifier and Type | Method and Description |
---|---|
void |
ActiveMQConnection.addTransportListener(TransportListener transportListener)
Adds a transport listener so that a client can be notified of events in
the underlying transport
|
void |
ActiveMQConnection.removeTransportListener(TransportListener transportListener) |
void |
ActiveMQConnectionFactory.setTransportListener(TransportListener transportListener)
Allows a listener to be configured on the ConnectionFactory so that when this factory is used
with frameworks which don't expose the Connection such as Spring JmsTemplate, you can still register
a transport listener.
|
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 |
DefaultTransportListener
An asynchronous listener of commands
|
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
correlation 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 |
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 TransportListener |
TransportFilter.transportListener |
Modifier and Type | Method and Description |
---|---|
TransportListener |
Transport.getTransportListener()
Returns the current transport listener
|
TransportListener |
TransportSupport.getTransportListener()
Returns the current transport listener
|
TransportListener |
TransportFilter.getTransportListener() |
Modifier and Type | Method and Description |
---|---|
void |
Transport.setTransportListener(TransportListener commandListener)
Registers an inbound command listener
|
void |
TransportSupport.setTransportListener(TransportListener commandListener)
Registers an inbound command listener
|
void |
TransportFilter.setTransportListener(TransportListener channelListener) |
Modifier and Type | Class and Description |
---|---|
class |
DiscoveryTransport
A
TransportFilter which uses a DiscoveryAgent to
discover remote broker instances and dynamically connect to them. |
Modifier and Type | Method and Description |
---|---|
TransportListener |
FailoverTransport.getTransportListener() |
Modifier and Type | Method and Description |
---|---|
void |
FailoverTransport.setTransportListener(TransportListener commandListener) |
Modifier and Type | Method and Description |
---|---|
TransportListener |
FanoutTransport.getTransportListener() |
Modifier and Type | Method and Description |
---|---|
void |
FanoutTransport.setTransportListener(TransportListener commandListener) |
Modifier and Type | Class and Description |
---|---|
class |
MockTransport |
Modifier and Type | Field and Description |
---|---|
protected TransportListener |
MockTransport.transportListener |
Modifier and Type | Method and Description |
---|---|
TransportListener |
MockTransport.getTransportListener() |
Modifier and Type | Method and Description |
---|---|
void |
MockTransport.setTransportListener(TransportListener channelListener) |
Modifier and Type | Class and Description |
---|---|
class |
MQTTInactivityMonitor |
class |
MQTTTransportFilter
The MQTTTransportFilter normally sits on top of a TcpTransport that has been
configured with the StompWireFormat and is used to convert MQTT commands to
ActiveMQ commands.
|
Modifier and Type | Class and Description |
---|---|
class |
ReliableTransport
Deprecated.
|
Modifier and Type | Class and Description |
---|---|
class |
StompInactivityMonitor
Used to make sure that commands are arriving periodically from the peer of
the transport.
|
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 | Class and Description |
---|---|
class |
ResponseRedirectInterceptor |
Modifier and Type | Field and Description |
---|---|
protected TransportListener |
VMTransport.transportListener |
Modifier and Type | Method and Description |
---|---|
TransportListener |
VMTransport.getTransportListener() |
Modifier and Type | Method and Description |
---|---|
void |
VMTransport.doDispatch(VMTransport transport,
TransportListener transportListener,
Object command) |
void |
VMTransport.setTransportListener(TransportListener commandListener) |
Copyright © 2005–2017. All rights reserved.