org.codehaus.activemq.transport.remote
Class RemoteTransportChannel
java.lang.Object
org.codehaus.activemq.transport.TransportChannelSupport
org.codehaus.activemq.transport.vm.VmTransportChannel
org.codehaus.activemq.transport.peer.PeerTransportChannel
org.codehaus.activemq.transport.remote.RemoteTransportChannel
- All Implemented Interfaces:
- Runnable, Service, TransportChannel
- public class RemoteTransportChannel
- extends PeerTransportChannel
A RemoteTransportChannel
creates an embedded broker that creates a remote connection to
another broker. This connection type is designed for reliable connections, that can use the storage
mechansims of an embedded broker to be decoupled from the remote broker - i.e. for connections that
need to be reliable, don't block but maybe using a transport across an unreliable network connection
An example of the expected format is: remote://tcp://remotebroker:5060
- Version:
- $Revision: 1.1 $
Fields inherited from class org.codehaus.activemq.transport.peer.PeerTransportChannel |
brokerConnector, brokerConnectorURI, brokerName, channel, DEFAULT_BROKER_CONNECTOR_URI, discoveryURI, doDiscovery, peerURIs, remote, remotePassword, remoteUserName, serviceName, wireFormat |
Methods inherited from class org.codehaus.activemq.transport.peer.PeerTransportChannel |
getBrokerConnectorURI, getBrokerName, getDiscoveryURI, getEmbeddedBrokerConnector, getPeerURIs, getRemotePassword, getRemoteUserName, getServiceName, getWireFormat, isDoDiscovery, isRemote, isTransportConnected, requiresEmbeddedBroker, setBrokerConnectorURI, setBrokerName, setDiscoveryURI, setDoDiscovery, setPeerURIs, setRemote, setRemotePassword, setRemoteUserName, setServiceName, setWireFormat |
Methods inherited from class org.codehaus.activemq.transport.vm.VmTransportChannel |
asyncSend, canProcessWireFormatVersion, connect, createChannel, createPacketListenerSender, createServerSide, doClose, forceDisconnect, getCurrentWireFormatVersion, getNextThreadId, getReceiveCapacity, getReceiveChannel, getSendCapacity, getSendChannel, isAsyncSend, isMulticast, run, setAsyncSend, setPacketListener, setReceiveCapacity, setReceiveChannel, setSendCapacity, setSendChannel, start, stop, toString |
Methods inherited from class org.codehaus.activemq.transport.TransportChannelSupport |
addTransportStatusEventListener, asyncSendWithReceipt, doAsyncSend, doConsumePacket, doConsumePacket, doHandleReceipt, doHandleWireFormat, fireStatusEvent, fireStatusEvent, getClientID, getExceptionListener, getLastReceiptTimestamp, getPacketListener, getTransportChannelListener, isPendingStop, isServerSide, onAsyncException, removeTransportStatusEventListener, send, send, setClientID, setExceptionListener, setPendingStop, setServerSide, setTransportChannelListener, setTransportConnected, stopExecutor |
RemoteTransportChannel
protected RemoteTransportChannel(WireFormat wireFormat,
String peerURIs)
throws JMSException
- Construct a RemoteTransportChannel
- Parameters:
wireFormat
- peerURIs
-
- Throws:
JMSException
createNetworkConnector
protected NetworkConnector createNetworkConnector(BrokerContainer container)
- Create a NetworkConnector
- Overrides:
createNetworkConnector
in class PeerTransportChannel
- Parameters:
container
-
- Returns:
- the NetworkConnector
Copyright © 2004-2005 Protique, Ltd.. All Rights Reserved.