|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use Transport | |
---|---|
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.ft | Helper classes for implementing fault tolerance |
org.apache.activemq.broker.jmx | JMX MBeans for the broker and its core connectors. |
org.apache.activemq.network | Support for federated networks of brokers. |
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.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. |
Uses of Transport in org.apache.activemq |
---|
Methods in org.apache.activemq that return Transport | |
---|---|
protected Transport |
ActiveMQSslConnectionFactory.createTransport()
Overriding to make special considerations for SSL connections. |
protected Transport |
ActiveMQConnectionFactory.createTransport()
Creates a Transport based on this object's connection settings. |
Transport |
ActiveMQConnection.getTransport()
|
Transport |
ActiveMQConnection.getTransportChannel()
|
Methods in org.apache.activemq with parameters of type Transport | |
---|---|
protected ActiveMQConnection |
ActiveMQConnectionFactory.createActiveMQConnection(Transport transport,
JMSStatsImpl stats)
|
protected ActiveMQConnection |
ActiveMQXAConnectionFactory.createActiveMQConnection(Transport transport,
JMSStatsImpl stats)
|
Constructors in org.apache.activemq with parameters of type Transport | |
---|---|
ActiveMQConnection(Transport transport,
IdGenerator clientIdGenerator,
IdGenerator connectionIdGenerator,
JMSStatsImpl factoryStats)
Construct an ActiveMQConnection |
|
ActiveMQXAConnection(Transport transport,
IdGenerator clientIdGenerator,
IdGenerator connectionIdGenerator,
JMSStatsImpl factoryStats)
|
Uses of Transport in org.apache.activemq.broker |
---|
Methods in org.apache.activemq.broker with parameters of type Transport | |
---|---|
protected Connection |
TransportConnector.createConnection(Transport transport)
|
Constructors in org.apache.activemq.broker with parameters of type Transport | |
---|---|
TransportConnection(TransportConnector connector,
Transport transport,
Broker broker,
TaskRunnerFactory taskRunnerFactory)
|
Uses of Transport in org.apache.activemq.broker.ft |
---|
Constructors in org.apache.activemq.broker.ft with parameters of type Transport | |
---|---|
MasterBroker(MutableBrokerFilter parent,
Transport transport)
Constructor |
Uses of Transport in org.apache.activemq.broker.jmx |
---|
Methods in org.apache.activemq.broker.jmx with parameters of type Transport | |
---|---|
protected Connection |
ManagedTransportConnector.createConnection(Transport transport)
|
Constructors in org.apache.activemq.broker.jmx with parameters of type Transport | |
---|---|
ManagedTransportConnection(TransportConnector connector,
Transport transport,
Broker broker,
TaskRunnerFactory factory,
ManagementContext context,
javax.management.ObjectName connectorName)
|
Uses of Transport in org.apache.activemq.network |
---|
Fields in org.apache.activemq.network declared as Transport | |
---|---|
protected Transport |
DemandForwardingBridgeSupport.localBroker
|
protected Transport |
DemandForwardingBridgeSupport.remoteBroker
|
Methods in org.apache.activemq.network that return Transport | |
---|---|
protected Transport |
NetworkConnector.createLocalTransport()
|
Transport |
DemandForwardingBridgeSupport.getLocalBroker()
|
Transport |
MulticastNetworkConnector.getLocalTransport()
|
Transport |
DemandForwardingBridgeSupport.getRemoteBroker()
|
Transport |
MulticastNetworkConnector.getRemoteTransport()
|
Methods in org.apache.activemq.network with parameters of type Transport | |
---|---|
static DemandForwardingBridge |
NetworkBridgeFactory.createBridge(NetworkBridgeConfiguration config,
Transport localTransport,
Transport remoteTransport)
Create a network bridge |
static DemandForwardingBridge |
NetworkBridgeFactory.createBridge(NetworkBridgeConfiguration configuration,
Transport localTransport,
Transport remoteTransport,
NetworkBridgeListener listener)
create a network bridge |
protected DemandForwardingBridgeSupport |
MulticastNetworkConnector.createBridge(Transport local,
Transport remote)
|
protected NetworkBridge |
DiscoveryNetworkConnector.createBridge(Transport localTransport,
Transport remoteTransport,
DiscoveryEvent event)
|
void |
MulticastNetworkConnector.setLocalTransport(Transport localTransport)
|
void |
MulticastNetworkConnector.setRemoteTransport(Transport remoteTransport)
Sets the remote transport implementation |
Constructors in org.apache.activemq.network with parameters of type Transport | |
---|---|
CompositeDemandForwardingBridge(NetworkBridgeConfiguration configuration,
Transport localBroker,
Transport remoteBroker)
|
|
ConduitBridge(NetworkBridgeConfiguration configuration,
Transport localBroker,
Transport remoteBroker)
Constructor |
|
DemandForwardingBridge(NetworkBridgeConfiguration configuration,
Transport localBroker,
Transport remoteBroker)
|
|
DemandForwardingBridgeSupport(NetworkBridgeConfiguration configuration,
Transport localBroker,
Transport remoteBroker)
|
|
DurableConduitBridge(NetworkBridgeConfiguration configuration,
Transport localBroker,
Transport remoteBroker)
Constructor |
|
ForwardingBridge(Transport localBroker,
Transport remoteBroker)
|
Uses of Transport in org.apache.activemq.state |
---|
Methods in org.apache.activemq.state with parameters of type Transport | |
---|---|
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)
|
Uses of Transport in org.apache.activemq.transport |
---|
Subinterfaces of Transport in org.apache.activemq.transport | |
---|---|
interface |
CompositeTransport
|
Classes in org.apache.activemq.transport that implement Transport | |
---|---|
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 corelation 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 |
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. |
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. |
Fields in org.apache.activemq.transport declared as Transport | |
---|---|
protected Transport |
TransportFilter.next
|
Methods in org.apache.activemq.transport that return Transport | |
---|---|
Transport |
TransportFactory.compositeConfigure(Transport transport,
WireFormat format,
java.util.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(java.net.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(java.net.URI location,
java.util.concurrent.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,
java.util.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(java.net.URI location)
Creates a normal transport. |
static Transport |
TransportFactory.connect(java.net.URI location,
java.util.concurrent.Executor ex)
Creates a normal transport. |
protected Transport |
TransportFactory.createTransport(java.net.URI location,
WireFormat wf)
Factory method to create a new transport |
Transport |
TransportFactory.doCompositeConnect(java.net.URI location)
|
Transport |
TransportFactory.doCompositeConnect(java.net.URI location,
java.util.concurrent.Executor ex)
|
Transport |
TransportFactory.doConnect(java.net.URI location)
|
Transport |
TransportFactory.doConnect(java.net.URI location,
java.util.concurrent.Executor ex)
|
Transport |
TransportFilter.getNext()
|
Transport |
TransportFactory.serverConfigure(Transport transport,
WireFormat format,
java.util.HashMap options)
Fully configures and adds all need transport filters so that the transport can be used by the ActiveMQ message broker. |
Methods in org.apache.activemq.transport with parameters of type Transport | |
---|---|
Transport |
TransportFactory.compositeConfigure(Transport transport,
WireFormat format,
java.util.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,
java.util.Map options)
Fully configures and adds all need transport filters so that the transport can be used by the JMS client. |
TransportLogger |
TransportLoggerFactory.createTransportLogger(Transport next)
Creates a TransportLogger object, that will be inserted in the Transport Stack. |
TransportLogger |
TransportLoggerFactory.createTransportLogger(Transport next,
int id,
org.slf4j.Logger log,
java.lang.String logWriterName,
boolean dynamicManagement,
boolean startLogging,
int jmxport)
Creates a TransportLogger object, that will be inserted in the Transport Stack. |
TransportLogger |
TransportLoggerFactory.createTransportLogger(Transport next,
org.slf4j.Logger log)
Creates a TransportLogger object, that will be inserted in the Transport Stack. |
TransportLogger |
TransportLoggerFactory.createTransportLogger(Transport next,
java.lang.String logWriterName,
boolean useJmx,
boolean startLogging,
int jmxport)
Creates a TransportLogger object, that will be inserted in the Transport Stack. |
void |
TransportAcceptListener.onAccept(Transport transport)
|
Transport |
TransportFactory.serverConfigure(Transport transport,
WireFormat format,
java.util.HashMap options)
Fully configures and adds all need transport filters so that the transport can be used by the ActiveMQ message broker. |
Constructors in org.apache.activemq.transport with parameters of type Transport | |
---|---|
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)
|
|
TransportLogger(Transport next,
org.slf4j.Logger log,
boolean startLogging,
LogWriter logWriter)
|
|
WireFormatNegotiator(Transport next,
OpenWireFormat wireFormat,
int minimumVersion)
Negotiator |
|
WriteTimeoutFilter(Transport next)
|
Uses of Transport in org.apache.activemq.transport.discovery |
---|
Classes in org.apache.activemq.transport.discovery that implement Transport | |
---|---|
class |
DiscoveryTransport
A ReliableTransportChannel which uses a DiscoveryAgent to
discover remote broker instances and dynamically connect to them. |
Methods in org.apache.activemq.transport.discovery that return Transport | |
---|---|
Transport |
DiscoveryTransportFactory.createTransport(URISupport.CompositeData compositeData)
|
Uses of Transport in org.apache.activemq.transport.failover |
---|
Classes in org.apache.activemq.transport.failover that implement Transport | |
---|---|
class |
FailoverTransport
A Transport that is made reliable by being able to fail over to another transport when a transport failure is detected. |
Methods in org.apache.activemq.transport.failover that return Transport | |
---|---|
Transport |
FailoverTransportFactory.createTransport(URISupport.CompositeData compositData)
|
Transport |
FailoverTransportFactory.doCompositeConnect(java.net.URI location)
|
Transport |
FailoverTransportFactory.doConnect(java.net.URI location)
|
Transport |
FailoverTransport.getConnectedTransport()
|
Methods in org.apache.activemq.transport.failover with parameters of type Transport | |
---|---|
void |
FailoverTransport.disposeTransport(Transport transport)
|
protected void |
FailoverTransport.restoreTransport(Transport t)
|
Uses of Transport in org.apache.activemq.transport.fanout |
---|
Classes in org.apache.activemq.transport.fanout that implement Transport | |
---|---|
class |
FanoutTransport
A Transport that fans out a connection to multiple brokers. |
Methods in org.apache.activemq.transport.fanout that return Transport | |
---|---|
Transport |
FanoutTransportFactory.createTransport(java.net.URI location)
|
Transport |
FanoutTransportFactory.doCompositeConnect(java.net.URI location)
|
Transport |
FanoutTransportFactory.doConnect(java.net.URI location)
|
Uses of Transport in org.apache.activemq.transport.mock |
---|
Classes in org.apache.activemq.transport.mock that implement Transport | |
---|---|
class |
MockTransport
|
Fields in org.apache.activemq.transport.mock declared as Transport | |
---|---|
protected Transport |
MockTransport.next
|
Methods in org.apache.activemq.transport.mock that return Transport | |
---|---|
Transport |
MockTransportFactory.createTransport(URISupport.CompositeData compositData)
|
Transport |
MockTransportFactory.doCompositeConnect(java.net.URI location)
|
Transport |
MockTransportFactory.doConnect(java.net.URI location)
|
Transport |
MockTransport.getNext()
|
Methods in org.apache.activemq.transport.mock with parameters of type Transport | |
---|---|
void |
MockTransport.setNext(Transport next)
|
Constructors in org.apache.activemq.transport.mock with parameters of type Transport | |
---|---|
MockTransport(Transport next)
|
Uses of Transport in org.apache.activemq.transport.mqtt |
---|
Classes in org.apache.activemq.transport.mqtt that implement Transport | |
---|---|
class |
MQTTInactivityMonitor
|
class |
MQTTNIOSSLTransport
|
class |
MQTTNIOTransport
An implementation of the Transport interface for using MQTT over NIO |
class |
MQTTTransportFilter
The MQTTTransportFilter normally sits on top of a TcpTransport that has been configured with the StompWireFormat and is used to convert MQTT commands to ActiveMQ commands. |
Methods in org.apache.activemq.transport.mqtt that return Transport | |
---|---|
Transport |
MQTTNIOTransportFactory.compositeConfigure(Transport transport,
WireFormat format,
java.util.Map options)
|
Transport |
MQTTTransportFactory.compositeConfigure(Transport transport,
WireFormat format,
java.util.Map options)
|
Transport |
MQTTSslTransportFactory.compositeConfigure(Transport transport,
WireFormat format,
java.util.Map options)
|
protected Transport |
MQTTNIOTransportFactory.createInactivityMonitor(Transport transport,
WireFormat format)
|
protected Transport |
MQTTTransportFactory.createInactivityMonitor(Transport transport,
WireFormat format)
|
protected Transport |
MQTTSslTransportFactory.createInactivityMonitor(Transport transport,
WireFormat format)
|
Transport |
MQTTNIOTransportFactory.serverConfigure(Transport transport,
WireFormat format,
java.util.HashMap options)
|
Transport |
MQTTTransportFactory.serverConfigure(Transport transport,
WireFormat format,
java.util.HashMap options)
|
Transport |
MQTTSslTransportFactory.serverConfigure(Transport transport,
WireFormat format,
java.util.HashMap options)
|
Methods in org.apache.activemq.transport.mqtt with parameters of type Transport | |
---|---|
Transport |
MQTTNIOTransportFactory.compositeConfigure(Transport transport,
WireFormat format,
java.util.Map options)
|
Transport |
MQTTTransportFactory.compositeConfigure(Transport transport,
WireFormat format,
java.util.Map options)
|
Transport |
MQTTSslTransportFactory.compositeConfigure(Transport transport,
WireFormat format,
java.util.Map options)
|
protected Transport |
MQTTNIOTransportFactory.createInactivityMonitor(Transport transport,
WireFormat format)
|
protected Transport |
MQTTTransportFactory.createInactivityMonitor(Transport transport,
WireFormat format)
|
protected Transport |
MQTTSslTransportFactory.createInactivityMonitor(Transport transport,
WireFormat format)
|
Transport |
MQTTNIOTransportFactory.serverConfigure(Transport transport,
WireFormat format,
java.util.HashMap options)
|
Transport |
MQTTTransportFactory.serverConfigure(Transport transport,
WireFormat format,
java.util.HashMap options)
|
Transport |
MQTTSslTransportFactory.serverConfigure(Transport transport,
WireFormat format,
java.util.HashMap options)
|
Constructors in org.apache.activemq.transport.mqtt with parameters of type Transport | |
---|---|
MQTTInactivityMonitor(Transport next,
WireFormat wireFormat)
|
|
MQTTTransportFilter(Transport next,
WireFormat wireFormat,
BrokerContext brokerContext)
|
Uses of Transport in org.apache.activemq.transport.multicast |
---|
Classes in org.apache.activemq.transport.multicast that implement Transport | |
---|---|
class |
MulticastTransport
A multicast based transport. |
Methods in org.apache.activemq.transport.multicast that return Transport | |
---|---|
protected Transport |
MulticastTransportFactory.createTransport(java.net.URI location,
WireFormat wf)
|
Uses of Transport in org.apache.activemq.transport.nio |
---|
Classes in org.apache.activemq.transport.nio that implement Transport | |
---|---|
class |
NIOSSLTransport
|
class |
NIOTransport
An implementation of the Transport interface using raw tcp/ip |
Methods in org.apache.activemq.transport.nio that return Transport | |
---|---|
Transport |
NIOSSLTransportFactory.compositeConfigure(Transport transport,
WireFormat format,
java.util.Map options)
Overriding to allow for proper configuration through reflection but delegate to get common configuration |
protected Transport |
NIOSSLTransportFactory.createTransport(java.net.URI location,
WireFormat wf)
Overriding to use SslTransports. |
Methods in org.apache.activemq.transport.nio with parameters of type Transport | |
---|---|
Transport |
NIOSSLTransportFactory.compositeConfigure(Transport transport,
WireFormat format,
java.util.Map options)
Overriding to allow for proper configuration through reflection but delegate to get common configuration |
Uses of Transport in org.apache.activemq.transport.peer |
---|
Methods in org.apache.activemq.transport.peer that return Transport | |
---|---|
Transport |
PeerTransportFactory.doCompositeConnect(java.net.URI location)
|
Transport |
PeerTransportFactory.doConnect(java.net.URI location)
|
Uses of Transport in org.apache.activemq.transport.reliable |
---|
Classes in org.apache.activemq.transport.reliable that implement Transport | |
---|---|
class |
ReliableTransport
This interceptor deals with out of order commands together with being able to handle dropped commands and the re-requesting dropped commands. |
Constructors in org.apache.activemq.transport.reliable with parameters of type Transport | |
---|---|
ReliableTransport(Transport next,
ReplayStrategy replayStrategy)
|
|
ReliableTransport(Transport next,
UdpTransport udpTransport)
|
Uses of Transport in org.apache.activemq.transport.stomp |
---|
Classes in org.apache.activemq.transport.stomp that implement Transport | |
---|---|
class |
StompInactivityMonitor
Used to make sure that commands are arriving periodically from the peer of the transport. |
class |
StompNIOSSLTransport
|
class |
StompNIOTransport
An implementation of the Transport interface for using Stomp over NIO |
class |
StompTransportFilter
The StompTransportFilter normally sits on top of a TcpTransport that has been configured with the StompWireFormat and is used to convert STOMP commands to ActiveMQ commands. |
Methods in org.apache.activemq.transport.stomp that return Transport | |
---|---|
Transport |
StompTransportFactory.compositeConfigure(Transport transport,
WireFormat format,
java.util.Map options)
|
Transport |
StompSslTransportFactory.compositeConfigure(Transport transport,
WireFormat format,
java.util.Map options)
|
Transport |
StompNIOTransportFactory.compositeConfigure(Transport transport,
WireFormat format,
java.util.Map options)
|
protected Transport |
StompTransportFactory.createInactivityMonitor(Transport transport,
WireFormat format)
|
Transport |
StompTransportFactory.serverConfigure(Transport transport,
WireFormat format,
java.util.HashMap options)
|
Transport |
StompSslTransportFactory.serverConfigure(Transport transport,
WireFormat format,
java.util.HashMap options)
|
Transport |
StompNIOTransportFactory.serverConfigure(Transport transport,
WireFormat format,
java.util.HashMap options)
|
Methods in org.apache.activemq.transport.stomp with parameters of type Transport | |
---|---|
Transport |
StompTransportFactory.compositeConfigure(Transport transport,
WireFormat format,
java.util.Map options)
|
Transport |
StompSslTransportFactory.compositeConfigure(Transport transport,
WireFormat format,
java.util.Map options)
|
Transport |
StompNIOTransportFactory.compositeConfigure(Transport transport,
WireFormat format,
java.util.Map options)
|
protected Transport |
StompTransportFactory.createInactivityMonitor(Transport transport,
WireFormat format)
|
Transport |
StompTransportFactory.serverConfigure(Transport transport,
WireFormat format,
java.util.HashMap options)
|
Transport |
StompSslTransportFactory.serverConfigure(Transport transport,
WireFormat format,
java.util.HashMap options)
|
Transport |
StompNIOTransportFactory.serverConfigure(Transport transport,
WireFormat format,
java.util.HashMap options)
|
Constructors in org.apache.activemq.transport.stomp with parameters of type Transport | |
---|---|
StompInactivityMonitor(Transport next,
WireFormat wireFormat)
|
|
StompTransportFilter(Transport next,
WireFormat wireFormat,
BrokerContext brokerContext)
|
Uses of Transport in org.apache.activemq.transport.tcp |
---|
Classes in org.apache.activemq.transport.tcp that implement Transport | |
---|---|
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 |
Methods in org.apache.activemq.transport.tcp that return Transport | |
---|---|
Transport |
TcpTransportFactory.compositeConfigure(Transport transport,
WireFormat format,
java.util.Map options)
|
Transport |
SslTransportFactory.compositeConfigure(Transport transport,
WireFormat format,
java.util.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(java.net.Socket socket,
WireFormat format)
Used to create Transports for this server. |
protected Transport |
TcpTransportServer.createTransport(java.net.Socket socket,
WireFormat format)
Allow derived classes to override the Transport implementation that this transport server creates. |
protected Transport |
TcpTransportFactory.createTransport(java.net.URI location,
WireFormat wf)
|
protected Transport |
SslTransportFactory.createTransport(java.net.URI location,
WireFormat wf)
Overriding to use SslTransports. |
Methods in org.apache.activemq.transport.tcp with parameters of type Transport | |
---|---|
Transport |
TcpTransportFactory.compositeConfigure(Transport transport,
WireFormat format,
java.util.Map options)
|
Transport |
SslTransportFactory.compositeConfigure(Transport transport,
WireFormat format,
java.util.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 |
Uses of Transport in org.apache.activemq.transport.udp |
---|
Classes in org.apache.activemq.transport.udp that implement Transport | |
---|---|
class |
ResponseRedirectInterceptor
|
class |
UdpTransport
An implementation of the Transport interface using raw UDP |
Methods in org.apache.activemq.transport.udp that return Transport | |
---|---|
Transport |
UdpTransportFactory.compositeConfigure(Transport transport,
WireFormat format,
java.util.Map options)
|
Transport |
UdpTransportFactory.configure(Transport transport,
WireFormat format,
java.util.Map options)
|
protected Transport |
UdpTransportFactory.configure(Transport transport,
WireFormat format,
java.util.Map options,
boolean acceptServer)
Configures the transport |
protected Transport |
UdpTransportFactory.configureClientSideNegotiator(Transport transport,
WireFormat format,
UdpTransport udpTransport)
|
protected Transport |
UdpTransportServer.configureTransport(Transport transport)
|
protected Transport |
UdpTransportServer.createTransport(Command command,
DatagramEndpoint endpoint)
|
protected Transport |
UdpTransportFactory.createTransport(int port,
WireFormat wf)
|
protected Transport |
UdpTransportFactory.createTransport(java.net.URI location,
WireFormat wf)
|
Methods in org.apache.activemq.transport.udp with parameters of type Transport | |
---|---|
Transport |
UdpTransportFactory.compositeConfigure(Transport transport,
WireFormat format,
java.util.Map options)
|
Transport |
UdpTransportFactory.configure(Transport transport,
WireFormat format,
java.util.Map options)
|
protected Transport |
UdpTransportFactory.configure(Transport transport,
WireFormat format,
java.util.Map options,
boolean acceptServer)
Configures the transport |
protected Transport |
UdpTransportFactory.configureClientSideNegotiator(Transport transport,
WireFormat format,
UdpTransport udpTransport)
|
protected Transport |
UdpTransportServer.configureTransport(Transport transport)
|
Constructors in org.apache.activemq.transport.udp with parameters of type Transport | |
---|---|
ResponseRedirectInterceptor(Transport next,
UdpTransport transport)
|
|
UdpTransportServer(java.net.URI connectURI,
UdpTransport serverTransport,
Transport configuredTransport,
ReplayStrategy replayStrategy)
|
Uses of Transport in org.apache.activemq.transport.vm |
---|
Classes in org.apache.activemq.transport.vm that implement Transport | |
---|---|
class |
VMTransport
A Transport implementation that uses direct method invocations. |
Methods in org.apache.activemq.transport.vm that return Transport | |
---|---|
static Transport |
VMTransportServer.configure(Transport transport)
Configure transport |
Transport |
VMTransportFactory.doCompositeConnect(java.net.URI location)
|
Transport |
VMTransportFactory.doConnect(java.net.URI location)
|
Methods in org.apache.activemq.transport.vm with parameters of type Transport | |
---|---|
static Transport |
VMTransportServer.configure(Transport transport)
Configure transport |
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |