org.apache.activemq.network
Class DemandForwardingBridge

java.lang.Object
  extended by org.apache.activemq.network.DemandForwardingBridgeSupport
      extended by org.apache.activemq.network.DemandForwardingBridge
All Implemented Interfaces:
Bridge, Service
Direct Known Subclasses:
ConduitBridge

public class DemandForwardingBridge
extends DemandForwardingBridgeSupport

Forwards messages from the local broker to the remote broker based on demand.

Version:
$Revision$

Field Summary
protected  Object brokerInfoMutex
           
protected  BrokerId remoteBrokerId
           
protected  BrokerId[] remoteBrokerPath
           
 
Fields inherited from class org.apache.activemq.network.DemandForwardingBridgeSupport
bridgeTempDestinations, consumerIdGenerator, decreaseNetworkConsumerPriority, demandConsumerDispatched, demandConsumerInfo, destinationFilter, dispatchAsync, disposed, durableDestinations, dynamicallyIncludedDestinations, excludedDestinations, idGenerator, lastConnectSucceeded, localBridgeStarted, localBroker, localBrokerId, localBrokerName, localBrokerPath, localClientId, localConnectionInfo, localSessionInfo, log, name, networkTTL, password, prefetchSize, producerInfo, remoteBridgeStarted, remoteBroker, remoteBrokerName, remoteBrokerNameKnownLatch, remoteConnectionInfo, remoteInterupted, startedLatch, staticallyIncludedDestinations, subscriptionMapByLocalId, subscriptionMapByRemoteId, userName
 
Constructor Summary
DemandForwardingBridge(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 org.apache.activemq.network.DemandForwardingBridgeSupport
addSubscription, appendToBrokerPath, appendToBrokerPath, clearDownSubscriptions, configureDemandSubscription, configureMessage, contains, createDemandSubscription, createDemandSubscription, doCreateDemandSubscription, getDemandSubscription, getDurableDestinations, getDynamicallyIncludedDestinations, getExcludedDestinations, getLocalBroker, getLocalBrokerName, getName, getNetworkTTL, getPassword, getPrefetchSize, getRemoteBroker, getStaticallyIncludedDestinations, getUserName, isBridgeTempDestinations, isDecreaseNetworkConsumerPriority, isDispatchAsync, isPermissableDestination, removeDemandSubscription, removeSubscription, serviceLocalCommand, serviceLocalException, serviceRemoteCommand, serviceRemoteException, setBridgeTempDestinations, setDecreaseNetworkConsumerPriority, setDispatchAsync, setDurableDestinations, setDynamicallyIncludedDestinations, setExcludedDestinations, setLocalBrokerName, setName, setNetworkTTL, setPassword, setPrefetchSize, setStaticallyIncludedDestinations, setupStaticDestinations, setUserName, start, startLocalBridge, startRemoteBridge, stop, triggerLocalStartBridge, triggerRemoteStartBridge, waitStarted
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

remoteBrokerPath

protected final BrokerId[] remoteBrokerPath

brokerInfoMutex

protected Object brokerInfoMutex

remoteBrokerId

protected BrokerId remoteBrokerId
Constructor Detail

DemandForwardingBridge

public DemandForwardingBridge(Transport localBroker,
                              Transport remoteBroker)
Method Detail

serviceRemoteBrokerInfo

protected void serviceRemoteBrokerInfo(Command command)
                                throws IOException
Specified by:
serviceRemoteBrokerInfo in class DemandForwardingBridgeSupport
Throws:
IOException

addRemoteBrokerToBrokerPath

protected void addRemoteBrokerToBrokerPath(ConsumerInfo info)
Specified by:
addRemoteBrokerToBrokerPath in class DemandForwardingBridgeSupport

serviceLocalBrokerInfo

protected void serviceLocalBrokerInfo(Command command)
                               throws InterruptedException
Specified by:
serviceLocalBrokerInfo in class DemandForwardingBridgeSupport
Throws:
InterruptedException

createNetworkBridgeFilter

protected NetworkBridgeFilter createNetworkBridgeFilter(ConsumerInfo info)
                                                 throws IOException
Specified by:
createNetworkBridgeFilter in class DemandForwardingBridgeSupport
Throws:
IOException

getRemoteBrokerPath

protected BrokerId[] getRemoteBrokerPath()
Specified by:
getRemoteBrokerPath in class DemandForwardingBridgeSupport


Copyright © 2011 Apache Software Foundation. All Rights Reserved.