org.codehaus.activemq.transport.remote
Class RemoteTransportChannel

java.lang.Object
  extended byorg.codehaus.activemq.transport.TransportChannelSupport
      extended byorg.codehaus.activemq.transport.vm.VmTransportChannel
          extended byorg.codehaus.activemq.transport.peer.PeerTransportChannel
              extended byorg.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 $

Field Summary
 
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
 
Fields inherited from class org.codehaus.activemq.transport.TransportChannelSupport
pendingStop, transportConnected
 
Constructor Summary
protected RemoteTransportChannel(WireFormat wireFormat, String peerURIs)
          Construct a RemoteTransportChannel
 
Method Summary
protected  NetworkConnector createNetworkConnector(BrokerContainer container)
          Create a NetworkConnector
 
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
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

RemoteTransportChannel

protected RemoteTransportChannel(WireFormat wireFormat,
                                 String peerURIs)
                          throws JMSException
Construct a RemoteTransportChannel

Parameters:
wireFormat -
peerURIs -
Throws:
JMSException
Method Detail

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.