org.apache.activemq.network
Class DurableConduitBridge
java.lang.Object
org.apache.activemq.network.DemandForwardingBridgeSupport
org.apache.activemq.network.DemandForwardingBridge
org.apache.activemq.network.ConduitBridge
org.apache.activemq.network.DurableConduitBridge
- All Implemented Interfaces:
- Bridge, Service
public class DurableConduitBridge
- extends ConduitBridge
Consolidates subscriptions
- Version:
- $Revision: 1.1 $
Fields inherited from class org.apache.activemq.network.DemandForwardingBridgeSupport |
bridgeTempDestinations, consumerIdGenerator, decreaseNetworkConsumerPriority, demandConsumerDispatched, demandConsumerInfo, destinationFilter, dispatchAsync, disposed, durableDestinations, dynamicallyIncludedDestinations, excludedDestinations, idGenerator, lastConnectSucceeded, localBridgeStarted, localBroker, localBrokerId, localBrokerName, localBrokerPath, localClientId, localConnectionInfo, localSessionInfo, name, networkTTL, password, prefetchSize, producerInfo, remoteBridgeStarted, remoteBroker, remoteBrokerName, remoteBrokerNameKnownLatch, remoteConnectionInfo, remoteInterupted, startedLatch, staticallyIncludedDestinations, subscriptionMapByLocalId, subscriptionMapByRemoteId, userName |
Methods inherited from class org.apache.activemq.network.DemandForwardingBridgeSupport |
addSubscription, appendToBrokerPath, appendToBrokerPath, clearDownSubscriptions, configureDemandSubscription, configureMessage, contains, createDemandSubscription, doCreateDemandSubscription, getDemandSubscription, getDurableDestinations, getDynamicallyIncludedDestinations, getExcludedDestinations, getLocalBroker, getLocalBrokerName, getName, getNetworkTTL, getPassword, getPrefetchSize, getRemoteBroker, getStaticallyIncludedDestinations, getUserName, isBridgeTempDestinations, isDecreaseNetworkConsumerPriority, isDispatchAsync, isPermissableDestination, removeSubscription, serviceLocalCommand, serviceLocalException, serviceRemoteCommand, serviceRemoteException, setBridgeTempDestinations, setDecreaseNetworkConsumerPriority, setDispatchAsync, setDurableDestinations, setDynamicallyIncludedDestinations, setExcludedDestinations, setLocalBrokerName, setName, setNetworkTTL, setPassword, setPrefetchSize, setStaticallyIncludedDestinations, setUserName, start, startLocalBridge, startRemoteBridge, stop, triggerLocalStartBridge, triggerRemoteStartBridge, waitStarted |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
DurableConduitBridge
public DurableConduitBridge(Transport localBroker,
Transport remoteBroker)
- Constructor
- Parameters:
localBroker
- remoteBroker
-
setupStaticDestinations
protected void setupStaticDestinations()
- Subscriptions for these destinations are always created
- Overrides:
setupStaticDestinations
in class DemandForwardingBridgeSupport
createDemandSubscription
protected DemandSubscription createDemandSubscription(ConsumerInfo info)
throws IOException
- Overrides:
createDemandSubscription
in class ConduitBridge
- Throws:
IOException
getSubscriberName
protected String getSubscriberName(ActiveMQDestination dest)
doesConsumerExist
protected boolean doesConsumerExist(ActiveMQDestination dest)
Copyright © 2011 Apache Software Foundation. All Rights Reserved.