public class DurableConduitBridge extends ConduitBridge
bridgeFailed, brokerService, configuration, consumerIdGenerator, defaultFilterFactory, demandConsumerDispatched, demandConsumerInfo, disposed, DURABLE_SUB_PREFIX, durableDestinations, dynamicallyIncludedDestinations, excludedDestinations, forcedDurableRemoteId, idGenerator, lastConnectSucceeded, localBridgeStarted, localBroker, localBrokerId, localBrokerPath, localClientId, localConnectionInfo, localSessionInfo, localStartedLatch, networkBridgeStatistics, producerInfo, remoteBridgeStarted, remoteBroker, remoteBrokerId, remoteBrokerName, remoteBrokerPath, remoteConnectionInfo, startedLatch, staticallyIncludedDestinations, staticDestinationsLatch, subscriptionMapByLocalId, subscriptionMapByRemoteId
Constructor and Description |
---|
DurableConduitBridge(NetworkBridgeConfiguration configuration,
Transport localBroker,
Transport remoteBroker)
Constructor
|
Modifier and Type | Method and Description |
---|---|
protected DemandSubscription |
createDemandSubscription(ConsumerInfo info) |
protected boolean |
doesConsumerExist(ActiveMQDestination dest) |
protected String |
getSubscriberName(ActiveMQDestination dest) |
protected void |
setupStaticDestinations()
Subscriptions for these destinations are always created
|
String |
toString() |
addToAlreadyInterestedConsumers, removeDemandSubscription
addConsumerInfo, addRemoteBrokerToBrokerPath, addSubscription, appendToBrokerPath, appendToBrokerPath, canDuplexDispatch, configureConsumerPrefetch, configureDemandSubscription, configureMessage, contains, 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, removeDemandSubscriptionByLocalId, removeSubscription, resetStats, safeWaitUntilStarted, serviceInboundMessage, serviceLocalCommand, serviceLocalException, serviceLocalException, serviceOutbound, serviceRemoteCommand, serviceRemoteException, setBrokerService, setCreatedByDuplex, setDurableDestinations, setDynamicallyIncludedDestinations, setExcludedDestinations, setMbeanObjectName, setNetworkBridgeListener, setStaticallyIncludedDestinations, start, startRemoteBridge, stop, triggerStartAsyncNetworkBridgeCreation
public DurableConduitBridge(NetworkBridgeConfiguration configuration, Transport localBroker, Transport remoteBroker)
configuration
- localBroker
- remoteBroker
- protected void setupStaticDestinations()
setupStaticDestinations
in class DemandForwardingBridgeSupport
protected DemandSubscription createDemandSubscription(ConsumerInfo info) throws IOException
createDemandSubscription
in class ConduitBridge
IOException
protected String getSubscriberName(ActiveMQDestination dest)
protected boolean doesConsumerExist(ActiveMQDestination dest)
Copyright © 2005–2024 The Apache Software Foundation. All rights reserved.