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:
BrokerServiceAware, NetworkBridge, Service
Direct Known Subclasses:
DurableConduitBridge

public class ConduitBridge
extends DemandForwardingBridge

Consolidates subscriptions


Field Summary
 
Fields inherited from class org.apache.activemq.network.DemandForwardingBridge
brokerInfoMutex, remoteBrokerId, remoteBrokerPath
 
Fields inherited from class org.apache.activemq.network.DemandForwardingBridgeSupport
configuration, consumerIdGenerator, demandConsumerDispatched, demandConsumerInfo, disposed, DURABLE_SUB_PREFIX, 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
 
Constructor Summary
ConduitBridge(NetworkBridgeConfiguration configuration, Transport localBroker, Transport remoteBroker)
          Constructor
 
Method Summary
protected  boolean addToAlreadyInterestedConsumers(ConsumerInfo info)
           
protected  boolean checkPaths(BrokerId[] first, BrokerId[] second)
           
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
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
 

Constructor Detail

ConduitBridge

public ConduitBridge(NetworkBridgeConfiguration configuration,
                     Transport localBroker,
                     Transport remoteBroker)
Constructor

Parameters:
localBroker -
remoteBroker -
Method Detail

createDemandSubscription

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

checkPaths

protected boolean checkPaths(BrokerId[] first,
                             BrokerId[] second)

addToAlreadyInterestedConsumers

protected boolean addToAlreadyInterestedConsumers(ConsumerInfo info)

removeDemandSubscription

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


Copyright © 2005-2011 FuseSource, Corp.. All Rights Reserved.