|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.activemq.network.DemandForwardingBridgeSupport
org.apache.activemq.network.DemandForwardingBridge
public class DemandForwardingBridge
Forwards messages from the local broker to the remote broker based on demand.
Field Summary | |
---|---|
protected java.lang.Object |
brokerInfoMutex
|
protected BrokerId |
remoteBrokerId
|
protected BrokerId[] |
remoteBrokerPath
|
Constructor Summary | |
---|---|
DemandForwardingBridge(NetworkBridgeConfiguration configuration,
Transport localBroker,
Transport remoteBroker)
|
Method Summary | |
---|---|
protected void |
addRemoteBrokerToBrokerPath(ConsumerInfo info)
|
protected NetworkBridgeFilter |
createNetworkBridgeFilter(ConsumerInfo info)
|
protected BrokerId[] |
getRemoteBrokerPath()
|
protected void |
serviceLocalBrokerInfo(Command command)
|
protected void |
serviceRemoteBrokerInfo(Command command)
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
protected final BrokerId[] remoteBrokerPath
protected java.lang.Object brokerInfoMutex
protected BrokerId remoteBrokerId
Constructor Detail |
---|
public DemandForwardingBridge(NetworkBridgeConfiguration configuration, Transport localBroker, Transport remoteBroker)
Method Detail |
---|
protected void serviceRemoteBrokerInfo(Command command) throws java.io.IOException
serviceRemoteBrokerInfo
in class DemandForwardingBridgeSupport
java.io.IOException
protected void addRemoteBrokerToBrokerPath(ConsumerInfo info)
addRemoteBrokerToBrokerPath
in class DemandForwardingBridgeSupport
protected void serviceLocalBrokerInfo(Command command) throws java.lang.InterruptedException
serviceLocalBrokerInfo
in class DemandForwardingBridgeSupport
java.lang.InterruptedException
protected NetworkBridgeFilter createNetworkBridgeFilter(ConsumerInfo info) throws java.io.IOException
createNetworkBridgeFilter
in class DemandForwardingBridgeSupport
java.io.IOException
protected BrokerId[] getRemoteBrokerPath()
getRemoteBrokerPath
in class DemandForwardingBridgeSupport
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |