|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.activemq.transport.NetworkChannel
org.activemq.transport.RemoteNetworkChannel
public class RemoteNetworkChannel
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.
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 java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Constructor Detail |
---|
public RemoteNetworkChannel(PooledExecutor tp)
tp
- public RemoteNetworkChannel(NetworkConnector connector, BrokerContainer brokerContainer, String uri)
connector
- brokerContainer
- uri
- Method Detail |
---|
public void statusChanged(TransportStatusEvent event)
TransportStatusEventListener
statusChanged
in interface TransportStatusEventListener
statusChanged
in class NetworkChannel
TransportStatusEventListener.statusChanged(org.activemq.transport.TransportStatusEvent)
protected void initialize() throws JMSException
initialize
in class NetworkChannel
JMSException
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |