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.jmx |
JMX MBeans for the broker and its core connectors.
|
org.apache.activemq.command |
Command objects used via the Command Pattern to communicate among nodes
|
org.apache.activemq.network |
Support for federated networks of brokers.
|
org.apache.activemq.proxy | |
org.apache.activemq.state | |
org.apache.activemq.transport |
The core Transport abstraction and support classes
|
org.apache.activemq.transport.auto | |
org.apache.activemq.transport.auto.nio | |
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.logwriters | |
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.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.
|
org.apache.activemq.transport.ws | |
org.apache.activemq.util |
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 |
---|
Transport
Represents the client side of a transport allowing messages to be sent
synchronously, asynchronously and consumed.
|
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.
|
TransportServer
A TransportServer asynchronously accepts
Transport objects and then
delivers those objects to a TransportAcceptListener . |
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 |
---|
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.
|
Class and Description |
---|
AbstractInactivityMonitor
Used to make sure that commands are arriving periodically from the peer of
the transport.
|
FutureResponse |
LogWriter
Interface for classes that will be called by the TransportLogger
class to actually write to a log file.
|
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
|
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.
|
TransportLoggerControlMBean
MBean used to manage all of the TransportLoggers at once.
|
TransportLoggerFactory
Singleton class to create TransportLogger objects.
|
TransportLoggerView
Class implementing the TransportLoggerViewMBean interface.
|
TransportLoggerViewMBean
MBean to manage a single Transport Logger.
|
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 |
---|
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. |
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 |
---|
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 |
---|
LogWriter
Interface for classes that will be called by the TransportLogger
class to actually write to a log file.
|
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 |
TransportFilter |
TransportListener
An asynchronous listener of commands
|
TransportServer
A TransportServer asynchronously accepts
Transport objects and then
delivers those objects to a TransportAcceptListener . |
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 |
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 |
---|
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 . |
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 |
---|
AbstractInactivityMonitor
Used to make sure that commands are arriving periodically from the peer of
the transport.
|
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 . |
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 |
---|
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.
|
Class and Description |
---|
FutureResponse |
ResponseCallback |
Transport
Represents the client side of a transport allowing messages to be sent
synchronously, asynchronously and consumed.
|
TransportAcceptListener |
TransportDisposedIOException
This is exception is thrown when the transport is disposed
|
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 |
---|
Transport
Represents the client side of a transport allowing messages to be sent
synchronously, asynchronously and consumed.
|
Class and Description |
---|
LogWriter
Interface for classes that will be called by the TransportLogger
class to actually write to a log file.
|
Copyright © 2005–2020 The Apache Software Foundation. All rights reserved.