org.codehaus.activemq.transport
Class RemoteNetworkChannel
java.lang.Object
org.codehaus.activemq.transport.NetworkChannel
org.codehaus.activemq.transport.RemoteNetworkChannel
- All Implemented Interfaces:
- ConsumerInfoListener, Service, TransportStatusEventListener
- public class RemoteNetworkChannel
- extends NetworkChannel
- implements TransportStatusEventListener
Represents a Boondocks broker's connection with a single remote broker which bridges the two brokers to form a network.
The NetworkChannel contains a JMS connection with the remote broker. New subscriptions on the local broker are
multiplexed into the JMS connection so that messages published on the remote broker can be replayed onto the local
broker.
- Version:
- $Revision: 1.2 $
Fields inherited from class org.codehaus.activemq.transport.NetworkChannel |
brokerContainer, consumerMap, localConnection, maximumRetries, reconnectSleepTime, remoteBrokerName, remoteClusterName, remoteConnection, remotePassword, remoteUserName, threadPool, uri |
Method Summary |
protected void |
initialize()
remote:// can only make outgoing connections - we assume we can't
accept incomming (duck!). |
void |
statusChanged(TransportStatusEvent event)
called when the status of a transport channel changes |
Methods inherited from class org.codehaus.activemq.transport.NetworkChannel |
getBrokerContainer, getLocalConnection, getMaximumRetries, getReconnectSleepTime, getRemoteBrokerName, getRemoteConnection, getRemotePassword, getRemoteUserName, getThreadPool, getUri, onConsumerInfo, setBrokerContainer, setMaximumRetries, setReconnectSleepTime, setRemoteBrokerName, setRemotePassword, setRemoteUserName, setThreadPool, setUri, start, stop, toString |
RemoteNetworkChannel
public RemoteNetworkChannel(PooledExecutor tp)
- Default Constructor
- Parameters:
tp
-
RemoteNetworkChannel
public RemoteNetworkChannel(NetworkConnector connector,
BrokerContainer brokerContainer,
String uri)
- Constructor
- Parameters:
connector
- brokerContainer
- uri
-
statusChanged
public void statusChanged(TransportStatusEvent event)
- Description copied from interface:
TransportStatusEventListener
- called when the status of a transport channel changes
- Specified by:
statusChanged
in interface TransportStatusEventListener
- Parameters:
event
- - See Also:
TransportStatusEventListener.statusChanged(org.codehaus.activemq.transport.TransportStatusEvent)
initialize
protected void initialize()
throws JMSException
- remote:// can only make outgoing connections - we assume we can't
accept incomming (duck!). So we initialize the transport channel
from this side and create the broker client as well
- Overrides:
initialize
in class NetworkChannel
- Throws:
JMSException
Copyright © 2004-2005 Protique, Ltd.. All Rights Reserved.