public class CompositeDemandForwardingBridge extends DemandForwardingBridgeSupport
Modifier and Type | Field and Description |
---|---|
protected java.lang.Object |
brokerInfoMutex |
protected BrokerId[] |
remoteBrokerPath |
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 and Description |
---|
CompositeDemandForwardingBridge(NetworkBridgeConfiguration configuration,
Transport localBroker,
Transport remoteBroker) |
Modifier and Type | Method and Description |
---|---|
protected void |
addRemoteBrokerToBrokerPath(ConsumerInfo info) |
protected NetworkBridgeFilter |
createNetworkBridgeFilter(ConsumerInfo info) |
protected BrokerId |
getFromBrokerId(Command command)
Returns the broker ID that the command came from
|
protected BrokerId[] |
getRemoteBrokerPath() |
protected void |
serviceLocalBrokerInfo(Command command) |
protected void |
serviceRemoteBrokerInfo(Command command) |
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
protected final BrokerId[] remoteBrokerPath
protected java.lang.Object brokerInfoMutex
public CompositeDemandForwardingBridge(NetworkBridgeConfiguration configuration, Transport localBroker, Transport remoteBroker)
protected void serviceRemoteBrokerInfo(Command command) throws java.io.IOException
serviceRemoteBrokerInfo
in class DemandForwardingBridgeSupport
java.io.IOException
protected void addRemoteBrokerToBrokerPath(ConsumerInfo info) throws java.io.IOException
addRemoteBrokerToBrokerPath
in class DemandForwardingBridgeSupport
java.io.IOException
protected BrokerId getFromBrokerId(Command command) throws java.io.IOException
java.io.IOException
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
Copyright © 2005-2012. All Rights Reserved.