public class ConduitBridge extends DemandForwardingBridge
brokerInfoMutex, remoteBrokerId, 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 |
---|
ConduitBridge(NetworkBridgeConfiguration configuration,
Transport localBroker,
Transport remoteBroker)
Constructor
|
Modifier and Type | Method and Description |
---|---|
protected boolean |
addToAlreadyInterestedConsumers(ConsumerInfo info) |
protected boolean |
checkPaths(BrokerId[] first,
BrokerId[] second) |
protected DemandSubscription |
createDemandSubscription(ConsumerInfo info) |
protected void |
removeDemandSubscription(ConsumerId id) |
addRemoteBrokerToBrokerPath, createNetworkBridgeFilter, getRemoteBrokerPath, serviceLocalBrokerInfo, serviceRemoteBrokerInfo
addConsumerInfo, addSubscription, appendToBrokerPath, appendToBrokerPath, clearDownSubscriptions, configureDemandSubscription, configureMessage, contains, createDemandSubscription, doCreateDemandSubscription, duplexStart, getControllingService, getDequeueCounter, getDurableDestinations, getDynamicallyIncludedDestinations, getEnqueueCounter, getExcludedDestinations, getLocalAddress, getLocalBroker, getLocalBrokerName, getRemoteAddress, getRemoteBroker, getRemoteBrokerName, getStaticallyIncludedDestinations, isCreatedByDuplex, isDuplex, isPermissableDestination, isPermissableDestination, removeDemandSubscriptionByLocalId, removeSubscription, serviceLocalCommand, serviceLocalException, serviceRemoteCommand, serviceRemoteException, setBrokerService, setCreatedByDuplex, setDurableDestinations, setDynamicallyIncludedDestinations, setExcludedDestinations, setNetworkBridgeListener, setStaticallyIncludedDestinations, setupStaticDestinations, start, startLocalBridge, startRemoteBridge, stop, triggerLocalStartBridge, triggerRemoteStartBridge, waitStarted
public ConduitBridge(NetworkBridgeConfiguration configuration, Transport localBroker, Transport remoteBroker)
localBroker
- remoteBroker
- protected DemandSubscription createDemandSubscription(ConsumerInfo info) throws java.io.IOException
createDemandSubscription
in class DemandForwardingBridgeSupport
java.io.IOException
protected boolean checkPaths(BrokerId[] first, BrokerId[] second)
protected boolean addToAlreadyInterestedConsumers(ConsumerInfo info)
protected void removeDemandSubscription(ConsumerId id) throws java.io.IOException
removeDemandSubscription
in class DemandForwardingBridgeSupport
java.io.IOException
Copyright © 2005-2012. All Rights Reserved.