org.apache.activemq.network
Class ConduitBridge
java.lang.Object
org.apache.activemq.network.DemandForwardingBridgeSupport
org.apache.activemq.network.DemandForwardingBridge
org.apache.activemq.network.ConduitBridge
- All Implemented Interfaces:
- BrokerServiceAware, NetworkBridge, Service
- Direct Known Subclasses:
- DurableConduitBridge
public class ConduitBridge
- extends DemandForwardingBridge
Consolidates subscriptions
- Version:
- $Revision: 1.1 $
Fields inherited from class org.apache.activemq.network.DemandForwardingBridgeSupport |
configuration, consumerIdGenerator, demandConsumerDispatched, demandConsumerInfo, disposed, 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 |
Methods inherited from class org.apache.activemq.network.DemandForwardingBridgeSupport |
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 |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
ConduitBridge
public ConduitBridge(NetworkBridgeConfiguration configuration,
Transport localBroker,
Transport remoteBroker)
- Constructor
- Parameters:
localBroker
- remoteBroker
-
createDemandSubscription
protected DemandSubscription createDemandSubscription(ConsumerInfo info)
throws IOException
- Overrides:
createDemandSubscription
in class DemandForwardingBridgeSupport
- Throws:
IOException
checkPaths
protected boolean checkPaths(BrokerId[] first,
BrokerId[] second)
addToAlreadyInterestedConsumers
protected boolean addToAlreadyInterestedConsumers(ConsumerInfo info)
removeDemandSubscription
protected void removeDemandSubscription(ConsumerId id)
throws IOException
- Overrides:
removeDemandSubscription
in class DemandForwardingBridgeSupport
- Throws:
IOException
Copyright © 2005-2011 Apache Software Foundation. All Rights Reserved.