Package | Description |
---|---|
org.apache.activemq |
The core JMS client API implementation classes.
|
org.apache.activemq.command |
Command objects used via the Command Pattern to communicate among nodes
|
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.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.tcp |
TCP/IP based Transport implementation.
|
org.apache.activemq.transport.udp |
UDP based Transport implementation.
|
Class and Description |
---|
Transport
Represents the client side of a transport allowing messages to be sent
synchronously, asynchronously and consumed.
|
TransportListener
An asynchronous listener of commands
|
Class and Description |
---|
TransmitCallback |
Class and Description |
---|
Transport
Represents the client side of a transport allowing messages to be sent
synchronously, asynchronously and consumed.
|
Class and Description |
---|
AbstractInactivityMonitor
Used to make sure that commands are arriving periodically from the peer of
the transport.
|
FutureResponse |
ResponseCallback |
Transport
Represents the client side of a transport allowing messages to be sent
synchronously, asynchronously and consumed.
|
TransportAcceptListener |
TransportFactory |
TransportFilter |
TransportListener
An asynchronous listener of commands
|
TransportServer
A TransportServer asynchronously accepts
Transport objects and then
delivers those objects to a TransportAcceptListener . |
TransportServerSupport
A useful base class for implementations of
TransportServer |
TransportSupport
A useful base class for transport implementations.
|
WriteTimeoutFilter
This filter implements write timeouts for socket write operations.
|
WriteTimeoutFilter.TimeoutThread |
Class and Description |
---|
CompositeTransport |
Transport
Represents the client side of a transport allowing messages to be sent
synchronously, asynchronously and consumed.
|
TransportFactory |
TransportFilter |
TransportListener
An asynchronous listener of commands
|
TransportServer
A TransportServer asynchronously accepts
Transport objects and then
delivers those objects to a TransportAcceptListener . |
Class and Description |
---|
CompositeTransport |
FutureResponse |
ResponseCallback |
Transport
Represents the client side of a transport allowing messages to be sent
synchronously, asynchronously and consumed.
|
TransportFactory |
TransportListener
An asynchronous listener of commands
|
TransportServer
A TransportServer asynchronously accepts
Transport objects and then
delivers those objects to a TransportAcceptListener . |
Class and Description |
---|
CompositeTransport |
FutureResponse |
ResponseCallback |
Transport
Represents the client side of a transport allowing messages to be sent
synchronously, asynchronously and consumed.
|
TransportFactory |
TransportListener
An asynchronous listener of commands
|
TransportServer
A TransportServer asynchronously accepts
Transport objects and then
delivers those objects to a TransportAcceptListener . |
Class and Description |
---|
DefaultTransportListener
An asynchronous listener of commands
|
FutureResponse |
ResponseCallback |
Transport
Represents the client side of a transport allowing messages to be sent
synchronously, asynchronously and consumed.
|
TransportFactory |
TransportFilter |
TransportListener
An asynchronous listener of commands
|
TransportServer
A TransportServer asynchronously accepts
Transport objects and then
delivers those objects to a TransportAcceptListener . |
Class and Description |
---|
Transport
Represents the client side of a transport allowing messages to be sent
synchronously, asynchronously and consumed.
|
TransportFactory |
TransportSupport
A useful base class for transport implementations.
|
TransportThreadSupport
A useful base class for a transport implementation which has a background
reading thread.
|
Class and Description |
---|
Transport
Represents the client side of a transport allowing messages to be sent
synchronously, asynchronously and consumed.
|
TransportFactory |
TransportServer
A TransportServer asynchronously accepts
Transport objects and then
delivers those objects to a TransportAcceptListener . |
TransportServerSupport
A useful base class for implementations of
TransportServer |
TransportServerThreadSupport
A useful base class for implementations of
TransportServer which uses
a background thread to accept new connections. |
TransportSupport
A useful base class for transport implementations.
|
TransportThreadSupport
A useful base class for a transport implementation which has a background
reading thread.
|
Class and Description |
---|
FutureResponse |
ResponseCorrelator
Adds the incrementing sequence number to commands along with performing the
correlation of responses to requests to create a blocking request-response
semantics.
|
Transport
Represents the client side of a transport allowing messages to be sent
synchronously, asynchronously and consumed.
|
TransportFilter |
TransportListener
An asynchronous listener of commands
|
Class and Description |
---|
Transport
Represents the client side of a transport allowing messages to be sent
synchronously, asynchronously and consumed.
|
TransportFactory |
TransportServer
A TransportServer asynchronously accepts
Transport objects and then
delivers those objects to a TransportAcceptListener . |
TransportServerSupport
A useful base class for implementations of
TransportServer |
TransportServerThreadSupport
A useful base class for implementations of
TransportServer which uses
a background thread to accept new connections. |
TransportSupport
A useful base class for transport implementations.
|
TransportThreadSupport
A useful base class for a transport implementation which has a background
reading thread.
|
Class and Description |
---|
Transport
Represents the client side of a transport allowing messages to be sent
synchronously, asynchronously and consumed.
|
TransportFactory |
TransportFilter |
TransportListener
An asynchronous listener of commands
|
TransportServer
A TransportServer asynchronously accepts
Transport objects and then
delivers those objects to a TransportAcceptListener . |
TransportServerSupport
A useful base class for implementations of
TransportServer |
TransportSupport
A useful base class for transport implementations.
|
TransportThreadSupport
A useful base class for a transport implementation which has a background
reading thread.
|
Copyright © 2005–2016 FuseSource, Corp.. All rights reserved.