|
||||||||||
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.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.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.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.xmpp |
Uses of Transport in org.apache.activemq |
---|
Methods in org.apache.activemq that return Transport | |
---|---|
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. |
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,
JMSStatsImpl factoryStats)
Construct an ActiveMQConnection |
|
ActiveMQXAConnection(Transport transport,
IdGenerator clientIdGenerator,
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 slave)
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,
MBeanServer server,
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 | |
---|---|
protected DemandForwardingBridgeSupport |
MulticastNetworkConnector.createBridge(Transport local,
Transport remote)
|
protected Bridge |
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(Transport localBroker,
Transport remoteBroker)
|
|
ConduitBridge(Transport localBroker,
Transport remoteBroker)
Constructor |
|
DemandForwardingBridge(Transport localBroker,
Transport remoteBroker)
|
|
DemandForwardingBridgeSupport(Transport localBroker,
Transport remoteBroker)
|
|
DurableConduitBridge(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.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 |
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
|
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 |
TransportFilter
|
class |
TransportLogger
|
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 |
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,
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,
edu.emory.mathcs.backport.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,
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,
edu.emory.mathcs.backport.java.util.concurrent.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,
edu.emory.mathcs.backport.java.util.concurrent.Executor ex)
|
Transport |
TransportFactory.doConnect(URI location)
|
Transport |
TransportFactory.doConnect(URI location,
edu.emory.mathcs.backport.java.util.concurrent.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. |
Methods in org.apache.activemq.transport with parameters of type Transport | |
---|---|
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. |
Constructors in org.apache.activemq.transport with parameters of type Transport | |
---|---|
CommandJoiner(Transport next,
OpenWireFormat wireFormat)
|
|
InactivityMonitor(Transport next)
|
|
MarshallingTransportFilter(Transport next,
WireFormat localWireFormat,
WireFormat remoteWireFormat)
|
|
MutexTransport(Transport next)
|
|
ResponseCorrelator(Transport next)
|
|
ResponseCorrelator(Transport next,
IntSequenceGenerator sequenceGenerator)
|
|
TransportFilter(Transport next)
|
|
TransportLogger(Transport next)
|
|
TransportLogger(Transport next,
org.apache.commons.logging.Log log)
|
|
WireFormatNegotiator(Transport next,
OpenWireFormat wireFormat,
int minimumVersion)
Negotiator |
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 compositData)
|
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(URI location)
|
Transport |
FailoverTransportFactory.doConnect(URI location)
|
Transport |
FailoverTransport.getConnectedTransport()
|
Methods in org.apache.activemq.transport.failover with parameters of type 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(URI location)
|
Transport |
FanoutTransportFactory.doCompositeConnect(URI location)
|
Transport |
FanoutTransportFactory.doConnect(URI location)
|
Uses of Transport in org.apache.activemq.transport.http |
---|
Classes in org.apache.activemq.transport.http that implement Transport | |
---|---|
class |
BlockingQueueTransport
A server side HTTP based TransportChannel which processes incoming packets and adds outgoing packets onto a Queue so that they can be dispatched
by the HTTP GET requests from the client. |
class |
HttpClientTransport
A HTTP org.apache.activemq.transport.TransportChannel which uses the commons-httpclient
library |
class |
HttpTransport
|
class |
HttpTransportSupport
A useful base class for HTTP Transport implementations. |
Methods in org.apache.activemq.transport.http that return Transport | |
---|---|
Transport |
HttpTransportFactory.compositeConfigure(Transport transport,
WireFormat format,
Map options)
|
protected Transport |
HttpTransportFactory.createTransport(URI location,
WireFormat wf)
|
Methods in org.apache.activemq.transport.http with parameters of type Transport | |
---|---|
Transport |
HttpTransportFactory.compositeConfigure(Transport transport,
WireFormat format,
Map options)
|
Uses of Transport in org.apache.activemq.transport.https |
---|
Classes in org.apache.activemq.transport.https that implement Transport | |
---|---|
class |
HttpsTransport
|
Methods in org.apache.activemq.transport.https that return Transport | |
---|---|
protected Transport |
HttpsTransportFactory.createTransport(URI location,
WireFormat wf)
|
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(URI location)
|
Transport |
MockTransportFactory.doConnect(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.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(URI location,
WireFormat wf)
|
Uses of Transport in org.apache.activemq.transport.peer |
---|
Methods in org.apache.activemq.transport.peer that return Transport | |
---|---|
Transport |
PeerTransportFactory.doCompositeConnect(URI location)
|
Transport |
PeerTransportFactory.doConnect(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 |
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 |
StompSslTransportFactory.compositeConfigure(Transport transport,
WireFormat format,
Map options)
|
Transport |
StompTransportFactory.compositeConfigure(Transport transport,
WireFormat format,
Map options)
|
Methods in org.apache.activemq.transport.stomp with parameters of type Transport | |
---|---|
Transport |
StompSslTransportFactory.compositeConfigure(Transport transport,
WireFormat format,
Map options)
|
Transport |
StompTransportFactory.compositeConfigure(Transport transport,
WireFormat format,
Map options)
|
Constructors in org.apache.activemq.transport.stomp with parameters of type Transport | |
---|---|
StompTransportFilter(Transport next,
FrameTranslator translator)
|
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 |
SslTransportFactory.compositeConfigure(Transport transport,
WireFormat format,
Map options)
Overriding to allow for proper configuration through reflection. |
Transport |
TcpTransportFactory.compositeConfigure(Transport transport,
WireFormat format,
Map options)
|
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 |
SslTransportFactory.createTransport(URI location,
WireFormat wf)
Overriding to use SslTransports. |
protected Transport |
TcpTransportFactory.createTransport(URI location,
WireFormat wf)
|
Methods in org.apache.activemq.transport.tcp with parameters of type Transport | |
---|---|
Transport |
SslTransportFactory.compositeConfigure(Transport transport,
WireFormat format,
Map options)
Overriding to allow for proper configuration through reflection. |
Transport |
TcpTransportFactory.compositeConfigure(Transport transport,
WireFormat format,
Map options)
|
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,
Map options)
|
Transport |
UdpTransportFactory.configure(Transport transport,
WireFormat format,
Map options)
|
protected Transport |
UdpTransportFactory.configure(Transport transport,
WireFormat format,
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(URI location,
WireFormat wf)
|
Methods in org.apache.activemq.transport.udp with parameters of type Transport | |
---|---|
Transport |
UdpTransportFactory.compositeConfigure(Transport transport,
WireFormat format,
Map options)
|
Transport |
UdpTransportFactory.configure(Transport transport,
WireFormat format,
Map options)
|
protected Transport |
UdpTransportFactory.configure(Transport transport,
WireFormat format,
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(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(URI location)
|
Transport |
VMTransportFactory.doConnect(URI location)
|
Methods in org.apache.activemq.transport.vm with parameters of type Transport | |
---|---|
static Transport |
VMTransportServer.configure(Transport transport)
Configure transport |
Uses of Transport in org.apache.activemq.transport.xmpp |
---|
Classes in org.apache.activemq.transport.xmpp that implement Transport | |
---|---|
class |
XmppTransport
|
Methods in org.apache.activemq.transport.xmpp that return Transport | |
---|---|
Transport |
XmppTransportFactory.compositeConfigure(Transport transport,
WireFormat format,
Map options)
|
protected Transport |
XmppTransportServer.createTransport(Socket socket,
WireFormat format)
|
Methods in org.apache.activemq.transport.xmpp with parameters of type Transport | |
---|---|
Transport |
XmppTransportFactory.compositeConfigure(Transport transport,
WireFormat format,
Map options)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |