Package | Description |
---|---|
org.apache.activemq |
The core JMS client API implementation classes.
|
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.
|
Modifier and Type | Method and Description |
---|---|
protected Transport |
ActiveMQConnectionFactory.createTransport()
Creates a Transport based on this object's connection settings.
|
protected Transport |
ActiveMQSslConnectionFactory.createTransport()
Overriding to make special considerations for SSL connections.
|
static Transport |
TransportLoggerSupport.createTransportLogger(Transport transport) |
Transport |
TransportLoggerSupport.SPI.createTransportLogger(Transport transport) |
static Transport |
TransportLoggerSupport.createTransportLogger(Transport transport,
String logWriterName,
boolean dynamicManagement,
boolean startLogging,
int jmxPort) |
Transport |
TransportLoggerSupport.SPI.createTransportLogger(Transport transport,
String logWriterName,
boolean dynamicManagement,
boolean startLogging,
int jmxPort) |
Transport |
ActiveMQConnection.getTransport() |
Transport |
ActiveMQConnection.getTransportChannel() |
Modifier and Type | Method and Description |
---|---|
protected ActiveMQConnection |
ActiveMQXAConnectionFactory.createActiveMQConnection(Transport transport,
JMSStatsImpl stats) |
protected ActiveMQConnection |
ActiveMQConnectionFactory.createActiveMQConnection(Transport transport,
JMSStatsImpl stats) |
static Transport |
TransportLoggerSupport.createTransportLogger(Transport transport) |
Transport |
TransportLoggerSupport.SPI.createTransportLogger(Transport transport) |
static Transport |
TransportLoggerSupport.createTransportLogger(Transport transport,
String logWriterName,
boolean dynamicManagement,
boolean startLogging,
int jmxPort) |
Transport |
TransportLoggerSupport.SPI.createTransportLogger(Transport transport,
String logWriterName,
boolean dynamicManagement,
boolean startLogging,
int jmxPort) |
Constructor and Description |
---|
ActiveMQConnection(Transport transport,
IdGenerator clientIdGenerator,
IdGenerator connectionIdGenerator,
JMSStatsImpl factoryStats)
Construct an
ActiveMQConnection |
ActiveMQXAConnection(Transport transport,
IdGenerator clientIdGenerator,
IdGenerator connectionIdGenerator,
JMSStatsImpl factoryStats) |
Modifier and Type | Method and Description |
---|---|
void |
ConnectionStateTracker.connectionInterruptProcessingComplete(Transport transport,
ConnectionId connectionId) |
void |
ConnectionStateTracker.restore(Transport transport) |
protected void |
ConnectionStateTracker.restoreConsumers(Transport transport,
SessionState sessionState) |
protected void |
ConnectionStateTracker.restoreProducers(Transport transport,
SessionState sessionState) |
protected void |
ConnectionStateTracker.restoreSessions(Transport transport,
ConnectionState connectionState) |
protected void |
ConnectionStateTracker.restoreTempDestinations(Transport transport,
ConnectionState connectionState) |
Modifier and Type | Interface and Description |
---|---|
interface |
CompositeTransport |
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 |
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 |
TransportSupport
A useful base class for transport implementations.
|
class |
TransportThreadSupport
A useful base class for a transport implementation which has a background
reading thread.
|
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 Transport |
TransportFilter.next |
Modifier and Type | Method and Description |
---|---|
Transport |
TransportFactory.compositeConfigure(Transport transport,
WireFormat format,
Map options)
Similar to configure(...) but this avoid adding in the MutexTransport and
ResponseCorrelator transport layers so that the resulting transport can
more efficiently be used as part of a composite transport.
|
static Transport |
TransportFactory.compositeConnect(URI location)
Creates a slimmed down transport that is more efficient so that it can be
used by composite transports like reliable and HA.
|
static Transport |
TransportFactory.compositeConnect(URI location,
Executor ex)
Creates a slimmed down transport that is more efficient so that it can be
used by composite transports like reliable and HA.
|
Transport |
TransportFactory.configure(Transport transport,
WireFormat wf,
Map options)
Fully configures and adds all need transport filters so that the
transport can be used by the JMS client.
|
static Transport |
TransportFactory.connect(URI location)
Creates a normal transport.
|
static Transport |
TransportFactory.connect(URI location,
Executor ex)
Creates a normal transport.
|
protected Transport |
TransportFactory.createTransport(URI location,
WireFormat wf)
Factory method to create a new transport
|
Transport |
TransportFactory.doCompositeConnect(URI location) |
Transport |
TransportFactory.doCompositeConnect(URI location,
Executor ex) |
Transport |
TransportFactory.doConnect(URI location) |
Transport |
TransportFactory.doConnect(URI location,
Executor ex) |
Transport |
TransportFilter.getNext() |
Transport |
TransportFactory.serverConfigure(Transport transport,
WireFormat format,
HashMap options)
Fully configures and adds all need transport filters so that the
transport can be used by the ActiveMQ message broker.
|
Modifier and Type | Method and Description |
---|---|
Transport |
TransportFactory.compositeConfigure(Transport transport,
WireFormat format,
Map options)
Similar to configure(...) but this avoid adding in the MutexTransport and
ResponseCorrelator transport layers so that the resulting transport can
more efficiently be used as part of a composite transport.
|
Transport |
TransportFactory.configure(Transport transport,
WireFormat wf,
Map options)
Fully configures and adds all need transport filters so that the
transport can be used by the JMS client.
|
void |
TransportAcceptListener.onAccept(Transport transport) |
Transport |
TransportFactory.serverConfigure(Transport transport,
WireFormat format,
HashMap options)
Fully configures and adds all need transport filters so that the
transport can be used by the ActiveMQ message broker.
|
Constructor and Description |
---|
AbstractInactivityMonitor(Transport next,
WireFormat wireFormat) |
CommandJoiner(Transport next,
OpenWireFormat wireFormat) |
InactivityMonitor(Transport next,
WireFormat wireFormat) |
MarshallingTransportFilter(Transport next,
WireFormat localWireFormat,
WireFormat remoteWireFormat) |
MutexTransport(Transport next) |
MutexTransport(Transport next,
boolean syncOnCommand) |
ResponseCorrelator(Transport next) |
ResponseCorrelator(Transport next,
IntSequenceGenerator sequenceGenerator) |
ThreadNameFilter(Transport next) |
TransportFilter(Transport next) |
WireFormatNegotiator(Transport next,
OpenWireFormat wireFormat,
int minimumVersion)
Negotiator
|
WriteTimeoutFilter(Transport next) |
Modifier and Type | Class and Description |
---|---|
class |
DiscoveryTransport
A
ReliableTransportChannel which uses a DiscoveryAgent to
discover remote broker instances and dynamically connect to them. |
Modifier and Type | Method and Description |
---|---|
Transport |
DiscoveryTransportFactory.createTransport(URISupport.CompositeData compositeData) |
Modifier and Type | Class and Description |
---|---|
class |
FailoverTransport
A Transport that is made reliable by being able to fail over to another
transport when a transport failure is detected.
|
Modifier and Type | Method and Description |
---|---|
Transport |
FailoverTransportFactory.createTransport(URISupport.CompositeData compositData) |
Transport |
FailoverTransportFactory.doCompositeConnect(URI location) |
Transport |
FailoverTransportFactory.doConnect(URI location) |
Transport |
FailoverTransport.getConnectedTransport() |
Modifier and Type | Method and Description |
---|---|
void |
FailoverTransport.disposeTransport(Transport transport) |
void |
FailoverTransport.handleTransportFailure(Transport failed,
IOException e) |
protected void |
FailoverTransport.restoreTransport(Transport t) |
Modifier and Type | Class and Description |
---|---|
class |
FanoutTransport
A Transport that fans out a connection to multiple brokers.
|
Modifier and Type | Method and Description |
---|---|
Transport |
FanoutTransportFactory.createTransport(URI location) |
Transport |
FanoutTransportFactory.doCompositeConnect(URI location) |
Transport |
FanoutTransportFactory.doConnect(URI location) |
Modifier and Type | Class and Description |
---|---|
class |
MockTransport |
Modifier and Type | Field and Description |
---|---|
protected Transport |
MockTransport.next |
Modifier and Type | Method and Description |
---|---|
Transport |
MockTransportFactory.createTransport(URISupport.CompositeData compositData) |
Transport |
MockTransportFactory.doCompositeConnect(URI location) |
Transport |
MockTransportFactory.doConnect(URI location) |
Transport |
MockTransport.getNext() |
Modifier and Type | Method and Description |
---|---|
void |
MockTransport.setNext(Transport next) |
Constructor and Description |
---|
MockTransport(Transport next) |
Modifier and Type | Class and Description |
---|---|
class |
MulticastTransport
A multicast based transport.
|
Modifier and Type | Method and Description |
---|---|
protected Transport |
MulticastTransportFactory.createTransport(URI location,
WireFormat wf) |
Modifier and Type | Class and Description |
---|---|
class |
NIOSSLTransport |
class |
NIOTransport
An implementation of the
Transport interface using raw tcp/ip |
Modifier and Type | Method and Description |
---|---|
Transport |
NIOSSLTransportFactory.compositeConfigure(Transport transport,
WireFormat format,
Map options)
Overriding to allow for proper configuration through reflection but
delegate to get common configuration
|
protected Transport |
NIOSSLTransportServer.createTransport(Socket socket,
WireFormat format) |
protected Transport |
NIOSSLTransportFactory.createTransport(URI location,
WireFormat wf)
Overriding to use SslTransports.
|
Modifier and Type | Method and Description |
---|---|
Transport |
NIOSSLTransportFactory.compositeConfigure(Transport transport,
WireFormat format,
Map options)
Overriding to allow for proper configuration through reflection but
delegate to get common configuration
|
Modifier and Type | Class and Description |
---|---|
class |
ReliableTransport
Deprecated.
|
Constructor and Description |
---|
ReliableTransport(Transport next,
ReplayStrategy replayStrategy)
Deprecated.
|
ReliableTransport(Transport next,
UdpTransport udpTransport)
Deprecated.
|
Modifier and Type | Class and Description |
---|---|
class |
SslTransport
A Transport class that uses SSL and client-side certificate authentication.
|
class |
TcpTransport
An implementation of the
Transport interface using raw tcp/ip |
Modifier and Type | Method and Description |
---|---|
Transport |
TcpTransportFactory.compositeConfigure(Transport transport,
WireFormat format,
Map options) |
Transport |
SslTransportFactory.compositeConfigure(Transport transport,
WireFormat format,
Map options)
Overriding to allow for proper configuration through reflection but delegate to get common
configuration
|
protected Transport |
TcpTransportFactory.createInactivityMonitor(Transport transport,
WireFormat format) |
protected Transport |
SslTransportServer.createTransport(Socket socket,
WireFormat format)
Used to create Transports for this server.
|
protected Transport |
TcpTransportServer.createTransport(Socket socket,
WireFormat format)
Allow derived classes to override the Transport implementation that this transport server creates.
|
protected Transport |
TcpTransportFactory.createTransport(URI location,
WireFormat wf) |
protected Transport |
SslTransportFactory.createTransport(URI location,
WireFormat wf)
Overriding to use SslTransports.
|
Modifier and Type | Method and Description |
---|---|
Transport |
TcpTransportFactory.compositeConfigure(Transport transport,
WireFormat format,
Map options) |
Transport |
SslTransportFactory.compositeConfigure(Transport transport,
WireFormat format,
Map options)
Overriding to allow for proper configuration through reflection but delegate to get common
configuration
|
protected Transport |
TcpTransportFactory.createInactivityMonitor(Transport transport,
WireFormat format) |
protected boolean |
TcpTransportFactory.isUseInactivityMonitor(Transport transport)
Returns true if the inactivity monitor should be used on the transport
|
Modifier and Type | Class and Description |
---|---|
class |
ResponseRedirectInterceptor |
class |
UdpTransport
An implementation of the
Transport interface using raw UDP |
Modifier and Type | Method and Description |
---|---|
Transport |
UdpTransportFactory.compositeConfigure(Transport transport,
WireFormat format,
Map options)
Deprecated.
|
Transport |
UdpTransportFactory.configure(Transport transport,
WireFormat format,
Map options)
Deprecated.
|
protected Transport |
UdpTransportFactory.configure(Transport transport,
WireFormat format,
Map options,
boolean acceptServer)
Deprecated.
Configures the transport
|
protected Transport |
UdpTransportFactory.configureClientSideNegotiator(Transport transport,
WireFormat format,
UdpTransport udpTransport)
Deprecated.
|
protected Transport |
UdpTransportServer.configureTransport(Transport transport)
Deprecated.
|
protected Transport |
UdpTransportServer.createTransport(Command command,
DatagramEndpoint endpoint)
Deprecated.
|
protected Transport |
UdpTransportFactory.createTransport(int port,
WireFormat wf)
Deprecated.
|
protected Transport |
UdpTransportFactory.createTransport(URI location,
WireFormat wf)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
Transport |
UdpTransportFactory.compositeConfigure(Transport transport,
WireFormat format,
Map options)
Deprecated.
|
Transport |
UdpTransportFactory.configure(Transport transport,
WireFormat format,
Map options)
Deprecated.
|
protected Transport |
UdpTransportFactory.configure(Transport transport,
WireFormat format,
Map options,
boolean acceptServer)
Deprecated.
Configures the transport
|
protected Transport |
UdpTransportFactory.configureClientSideNegotiator(Transport transport,
WireFormat format,
UdpTransport udpTransport)
Deprecated.
|
protected Transport |
UdpTransportServer.configureTransport(Transport transport)
Deprecated.
|
Constructor and Description |
---|
ResponseRedirectInterceptor(Transport next,
UdpTransport transport) |
UdpTransportServer(URI connectURI,
UdpTransport serverTransport,
Transport configuredTransport,
ReplayStrategy replayStrategy)
Deprecated.
|
Copyright © 2005–2016 FuseSource, Corp.. All rights reserved.