org.apache.activemq.network
Class DemandForwardingBridge

java.lang.Object
  org.apache.activemq.network.DemandForwardingBridgeSupport
      org.apache.activemq.network.DemandForwardingBridge

All Implemented Interfaces:

BrokerServiceAware, NetworkBridge, Service

Direct Known Subclasses:

ConduitBridge

public class DemandForwardingBridge
extends DemandForwardingBridgeSupport

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

Fields inherited from class org.apache.activemq.network.DemandForwardingBridgeSupport

configuration, consumerIdGenerator, demandConsumerDispatched, demandConsumerInfo, disposed, DURABLE_SUB_PREFIX, durableDestinations, dynamicallyIncludedDestinations, excludedDestinations, idGenerator, lastConnectSucceeded, localBridgeStarted, localBroker, localBrokerId, localBrokerIdKnownLatch, localBrokerPath, localClientId, localConnectionInfo, localSessionInfo, localStartedLatch, producerInfo, remoteBridgeStarted, remoteBroker, remoteBrokerName, remoteBrokerNameKnownLatch, remoteConnectionInfo, remoteInterupted, startedLatch, staticallyIncludedDestinations, subscriptionMapByLocalId, subscriptionMapByRemoteId

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 org.apache.activemq.network.DemandForwardingBridgeSupport

addConsumerInfo, addSubscription, appendToBrokerPath, appendToBrokerPath, clearDownSubscriptions, configureDemandSubscription, configureMessage, contains, createDemandSubscription, createDemandSubscription, doCreateDemandSubscription, duplexStart, getControllingService, getDequeueCounter, getDurableDestinations, getDynamicallyIncludedDestinations, getEnqueueCounter, getExcludedDestinations, getLocalAddress, getLocalBroker, getLocalBrokerName, getRemoteAddress, getRemoteBroker, getRemoteBrokerName, getStaticallyIncludedDestinations, isCreatedByDuplex, isDuplex, isPermissableDestination, isPermissableDestination, removeDemandSubscription, removeDemandSubscriptionByLocalId, removeSubscription, serviceLocalCommand, serviceLocalException, serviceRemoteCommand, serviceRemoteException, setBrokerService, setCreatedByDuplex, setDurableDestinations, setDynamicallyIncludedDestinations, setExcludedDestinations, setNetworkBridgeListener, setStaticallyIncludedDestinations, setupStaticDestinations, 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 java.lang.Object brokerInfoMutex

remoteBrokerId

protected BrokerId remoteBrokerId

Constructor Detail

DemandForwardingBridge

public DemandForwardingBridge(NetworkBridgeConfiguration configuration,
                              Transport localBroker,
                              Transport remoteBroker)

Method Detail

serviceRemoteBrokerInfo

protected void serviceRemoteBrokerInfo(Command command)
                                throws java.io.IOException

Specified by:

serviceRemoteBrokerInfo in class DemandForwardingBridgeSupport

Throws:

java.io.IOException

addRemoteBrokerToBrokerPath

protected void addRemoteBrokerToBrokerPath(ConsumerInfo info)

Specified by:

addRemoteBrokerToBrokerPath in class DemandForwardingBridgeSupport

serviceLocalBrokerInfo

protected void serviceLocalBrokerInfo(Command command)
                               throws java.lang.InterruptedException

Specified by:

serviceLocalBrokerInfo in class DemandForwardingBridgeSupport

Throws:

java.lang.InterruptedException

createNetworkBridgeFilter

protected NetworkBridgeFilter createNetworkBridgeFilter(ConsumerInfo info)
                                                 throws java.io.IOException

Specified by:

createNetworkBridgeFilter in class DemandForwardingBridgeSupport

Throws:

java.io.IOException

getRemoteBrokerPath

protected BrokerId[] getRemoteBrokerPath()

Specified by:

getRemoteBrokerPath in class DemandForwardingBridgeSupport