org.apache.activemq.network
Class ConduitBridge

java.lang.Object
  extended by org.apache.activemq.network.DemandForwardingBridgeSupport
      extended by org.apache.activemq.network.DemandForwardingBridge
          extended by org.apache.activemq.network.ConduitBridge
All Implemented Interfaces:
Bridge, Service
Direct Known Subclasses:
DurableConduitBridge

public class ConduitBridge
extends DemandForwardingBridge

Consolidates subscriptions

Version:
$Revision: 1.1 $

Field Summary
 
Fields inherited from class org.apache.activemq.network.DemandForwardingBridge
brokerInfoMutex, remoteBrokerId, remoteBrokerPath
 
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
 
Constructor Summary
ConduitBridge(Transport localBroker, Transport remoteBroker)
          Constructor
 
Method Summary
protected  boolean addToAlreadyInterestedConsumers(ConsumerInfo info)
           
protected  DemandSubscription createDemandSubscription(ConsumerInfo info)
           
protected  void removeDemandSubscription(ConsumerId id)
           
 
Methods inherited from class org.apache.activemq.network.DemandForwardingBridge
addRemoteBrokerToBrokerPath, createNetworkBridgeFilter, getRemoteBrokerPath, serviceLocalBrokerInfo, serviceRemoteBrokerInfo
 
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, setupStaticDestinations, 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
 

Constructor Detail

ConduitBridge

public ConduitBridge(Transport localBroker,
                     Transport remoteBroker)
Constructor

Parameters:
localBroker -
remoteBroker -
Method Detail

createDemandSubscription

protected DemandSubscription createDemandSubscription(ConsumerInfo info)
                                               throws IOException
Overrides:
createDemandSubscription in class DemandForwardingBridgeSupport
Throws:
IOException

addToAlreadyInterestedConsumers

protected boolean addToAlreadyInterestedConsumers(ConsumerInfo info)

removeDemandSubscription

protected void removeDemandSubscription(ConsumerId id)
                                 throws IOException
Overrides:
removeDemandSubscription in class DemandForwardingBridgeSupport
Throws:
IOException


Copyright © 2011 Apache Software Foundation. All Rights Reserved.