public class CompositeDemandForwardingBridge extends DemandForwardingBridgeSupport
bridgeFailed, brokerService, configuration, consumerIdGenerator, defaultFilterFactory, demandConsumerDispatched, demandConsumerInfo, disposed, DURABLE_SUB_PREFIX, durableDestinations, dynamicallyIncludedDestinations, excludedDestinations, idGenerator, lastConnectSucceeded, localBridgeStarted, localBroker, localBrokerId, localBrokerPath, localClientId, localConnectionInfo, localSessionInfo, localStartedLatch, networkBridgeStatistics, producerInfo, remoteBridgeStarted, remoteBroker, remoteBrokerId, remoteBrokerName, remoteBrokerPath, remoteConnectionInfo, startedLatch, staticallyIncludedDestinations, subscriptionMapByLocalId, subscriptionMapByRemoteId
Constructor and Description |
---|
CompositeDemandForwardingBridge(NetworkBridgeConfiguration configuration,
Transport localBroker,
Transport remoteBroker) |
Modifier and Type | Method and Description |
---|---|
protected void |
serviceLocalBrokerInfo(Command command) |
addConsumerInfo, addRemoteBrokerToBrokerPath, addSubscription, appendToBrokerPath, appendToBrokerPath, canDuplexDispatch, configureDemandSubscription, configureMessage, contains, createDemandSubscription, createDemandSubscription, createNetworkBridgeFilter, doCreateDemandSubscription, duplexStart, getControllingService, getDequeueCounter, getDurableDestinations, getDynamicallyIncludedDestinations, getEnqueueCounter, getExcludedDestinations, getLocalAddress, getLocalBroker, getLocalBrokerName, getLocalSubscriptionMap, getMbeanObjectName, getNetworkBridgeStatistics, getRegionSubscriptions, getRemoteAddress, getRemoteBroker, getRemoteBrokerId, getRemoteBrokerName, getRemoteBrokerPath, getStaticallyIncludedDestinations, getStoredSequenceIdForMessage, isCreatedByDuplex, isDuplex, isPermissableDestination, isPermissableDestination, removeDemandSubscription, removeDemandSubscriptionByLocalId, removeSubscription, resetStats, safeWaitUntilStarted, serviceInboundMessage, serviceLocalCommand, serviceLocalException, serviceLocalException, serviceOutbound, serviceRemoteCommand, serviceRemoteException, setBrokerService, setCreatedByDuplex, setDurableDestinations, setDynamicallyIncludedDestinations, setExcludedDestinations, setMbeanObjectName, setNetworkBridgeListener, setStaticallyIncludedDestinations, setupStaticDestinations, start, startRemoteBridge, stop, triggerStartAsyncNetworkBridgeCreation
public CompositeDemandForwardingBridge(NetworkBridgeConfiguration configuration, Transport localBroker, Transport remoteBroker)
protected void serviceLocalBrokerInfo(Command command) throws InterruptedException
InterruptedException
Copyright © 2005–2016 The Apache Software Foundation. All rights reserved.