org.activemq.transport
Class RemoteNetworkChannel

java.lang.Object
  extended by org.activemq.transport.NetworkChannel
      extended by org.activemq.transport.RemoteNetworkChannel
All Implemented Interfaces:
ConnectionAdvisoryEventListener, 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.1.1.1 $

Field Summary
 
Fields inherited from class org.activemq.transport.NetworkChannel
brokerContainer, localConnection, maximumRetries, queueConsumerMap, reconnectSleepTime, remoteBrokerName, remoteClusterName, remoteConnection, remotePassword, remoteUserName, threadPool, topicConsumerMap, uri
 
Constructor Summary
RemoteNetworkChannel(NetworkConnector connector, BrokerContainer brokerContainer, String uri)
          Constructor
RemoteNetworkChannel(PooledExecutor tp)
          Default Constructor
 
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.activemq.transport.NetworkChannel
getBrokerContainer, getLocalPrefetchPolicy, getMaximumRetries, getReconnectSleepTime, getRemoteBrokerName, getRemotePassword, getRemotePrefetchPolicy, getRemoteUserName, getThreadPool, getUri, isDemandBasedForwarding, onConsumerInfo, onEvent, setBrokerContainer, setDemandBasedForwarding, setLocalPrefetchPolicy, setMaximumRetries, setReconnectSleepTime, setRemoteBrokerName, setRemotePassword, setRemotePrefetchPolicy, setRemoteUserName, setThreadPool, setUri, start, stop, toString
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

RemoteNetworkChannel

public RemoteNetworkChannel(PooledExecutor tp)
Default Constructor

Parameters:
tp -

RemoteNetworkChannel

public RemoteNetworkChannel(NetworkConnector connector,
                            BrokerContainer brokerContainer,
                            String uri)
Constructor

Parameters:
connector -
brokerContainer -
uri -
Method Detail

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
Overrides:
statusChanged in class NetworkChannel
See Also:
TransportStatusEventListener.statusChanged(org.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-2009 Protique, Ltd.. All Rights Reserved.