org.apache.activemq.transport.discovery | Discovery mechanism to discover brokers and clients. |
org.apache.activemq.transport.discovery.http | |
org.apache.activemq.transport.discovery.multicast | Discovery implementation using multicast |
org.apache.activemq.transport.discovery.rendezvous | A discovery agent using Zeroconf via the jmDNS library |
org.apache.activemq.transport.discovery.simple | Simple discovery implementation using a static list |
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.http | A transport using the HTTP protocol to allow ActiveMQ to tunnel through firewalls. |
org.apache.activemq.transport.https | A transport using the HTTPS protocol (built on top of the HTTP transport) to allow ActiveMQ to tunnel through firewalls using SSL. |
org.apache.activemq.transport.logwriters | |
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.util | |
org.apache.activemq.transport.vm | In-JVM based Transport implementation. |
org.apache.activemq.transport.xmpp | |
org.apache.activemq.transport.xmpp.command | |
org.apache.activemq.transport.xstream |
CompositeTransport | Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. | code | html |
LogWriter | Interface for classes that will be called by the TransportLogger class to actually write to a log file. | code | html |
ResponseCallback | code | html | |
Transport | Represents the client side of a transport allowing messages to be sent synchronously, asynchronously and consumed. | code | html |
TransportAcceptListener | Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. | code | html |
TransportListener | An asynchronous listener of commands | code | html |
TransportLoggerControlMBean | MBean used to manage all of the TransportLoggers at once. | code | html |
TransportLoggerViewMBean | MBean to manage a single Transport Logger. | code | html |
TransportServer | A TransportServer asynchronously accepts {@see Transport} objects and then delivers those objects to a {@see TransportAcceptListener}. | code | html |
TransportFactory | Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. | code | html |
TransportServerSupport | A useful base class for implementations of TransportServer | code | html |
TransportServerThreadSupport | A useful base class for implementations of TransportServer which uses a background thread to accept new connections. | code | html |
TransportSupport | A useful base class for transport implementations. | code | html |
TransportThreadSupport | A useful base class for a transport implementation which has a background reading thread. | code | html |
CommandJoiner | Joins together of partial commands which were split into individual chunks of data. | code | html |
DefaultTransportListener | An asynchronous listener of commands | code | html |
FutureResponse | Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. | code | html |
InactivityIOException | This is exception is thrown when the transport layer detects that the underlying socket has been inactive for too long. | code | html |
InactivityMonitor | Used to make sure that commands are arriving periodically from the peer of the transport. | code | html |
MarshallingTransportFilter | Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. | code | html |
MutexTransport | code | html | |
ResponseCorrelator | Adds the incrementing sequence number to commands along with performing the corelation of responses to requests to create a blocking request-response semantics. | code | html |
ThreadNameFilter | The thread name filter, modifies the name of the thread during the invocation to a transport. | code | html |
TransportDisposedIOException | This is exception is thrown when the transport is disposed | code | html |
TransportFilter | code | html | |
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. | code | html |
TransportLoggerControl | Implementation of the TransportLoggerControlMBean interface, which is an MBean used to control all TransportLoggers at once. | code | html |
TransportLoggerFactory | Singleton class to create TransportLogger objects. | code | html |
TransportLoggerView | Class implementing the TransportLoggerViewMBean interface. | code | html |
TransportServerFilter | Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. | code | html |
WireFormatNegotiator | Negotiates the wire format with a new connection | code | html |
WriteTimeoutFilter | This filter implements write timeouts for socket write operations. | code | html |
WriteTimeoutFilter.TimeoutThread | code | html |