public class ConduitBridge extends DemandForwardingBridge
brokerInfoMutex, configuration, consumerIdGenerator, defaultFilterFactory, demandConsumerDispatched, demandConsumerInfo, disposed, DURABLE_SUB_PREFIX, durableDestinations, dynamicallyIncludedDestinations, excludedDestinations, idGenerator, lastConnectSucceeded, localBridgeStarted, localBroker, localBrokerId, localBrokerPath, localClientId, localConnectionInfo, localSessionInfo, localStartedLatch, producerInfo, remoteBridgeStarted, remoteBroker, remoteBrokerId, remoteBrokerName, remoteBrokerPath, remoteConnectionInfo, 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) |
addConsumerInfo, addRemoteBrokerToBrokerPath, addSubscription, appendToBrokerPath, appendToBrokerPath, clearDownSubscriptions, configureDemandSubscription, configureMessage, contains, createDemandSubscription, createNetworkBridgeFilter, doCreateDemandSubscription, duplexStart, getControllingService, getDequeueCounter, getDurableDestinations, getDynamicallyIncludedDestinations, getEnqueueCounter, getExcludedDestinations, getLocalAddress, getLocalBroker, getLocalBrokerName, getLocalSubscriptionMap, getMbeanObjectName, getRemoteAddress, getRemoteBroker, getRemoteBrokerName, getRemoteBrokerPath, getStaticallyIncludedDestinations, isCreatedByDuplex, isDuplex, isPermissableDestination, isPermissableDestination, removeDemandSubscriptionByLocalId, removeSubscription, serviceLocalBrokerInfo, serviceLocalCommand, serviceLocalException, serviceRemoteBrokerInfo, serviceRemoteCommand, serviceRemoteException, setBrokerService, setCreatedByDuplex, setDurableDestinations, setDynamicallyIncludedDestinations, setExcludedDestinations, setMbeanObjectName, setNetworkBridgeListener, setStaticallyIncludedDestinations, setupStaticDestinations, start, startRemoteBridge, stop, triggerLocalStartBridge, triggerRemoteStartBridge, waitStarted
public ConduitBridge(NetworkBridgeConfiguration configuration, Transport localBroker, Transport remoteBroker)
localBroker
- remoteBroker
- protected DemandSubscription createDemandSubscription(ConsumerInfo info) throws IOException
createDemandSubscription
in class DemandForwardingBridgeSupport
IOException
protected boolean checkPaths(BrokerId[] first, BrokerId[] second)
protected boolean addToAlreadyInterestedConsumers(ConsumerInfo info)
protected void removeDemandSubscription(ConsumerId id) throws IOException
removeDemandSubscription
in class DemandForwardingBridgeSupport
IOException
Copyright © 2005–2015. All rights reserved.