public class DemandForwardingBridge extends DemandForwardingBridgeSupport
Modifier and Type | Field and Description |
---|---|
protected java.lang.Object |
brokerInfoMutex |
protected BrokerId |
remoteBrokerId |
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 |
---|
DemandForwardingBridge(NetworkBridgeConfiguration configuration,
Transport localBroker,
Transport remoteBroker) |
Modifier and Type | Method and Description |
---|---|
protected void |
addRemoteBrokerToBrokerPath(ConsumerInfo info) |
protected NetworkBridgeFilter |
createNetworkBridgeFilter(ConsumerInfo info) |
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
protected BrokerId remoteBrokerId
public DemandForwardingBridge(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)
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
Copyright © 2005-2012. All Rights Reserved.