Home » activemq-parent-5.3.1-source-release » org.apache » activemq » transport »

org.apache.activemq.transport

Sub Packages:

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    

Interfaces:

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

Abstract Classes:

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

Classes:

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