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.DemandForwardingBridgeSupport
bridgeFailed, brokerService, configuration, consumerIdGenerator, defaultFilterFactory, demandConsumerDispatched, demandConsumerInfo, disposed, DURABLE_SUB_PREFIX, durableDestinations, dynamicallyIncludedDestinations, excludedDestinations, idGenerator, lastConnectSucceeded, localBridgeStarted, localBroker, localBrokerId, localBrokerPath, localClientId, localConnectionInfo, localSessionInfo, localStartedLatch, producerInfo, remoteBridgeStarted, remoteBroker, remoteBrokerId, remoteBrokerName, remoteBrokerPath, remoteConnectionInfo, startedLatch, staticallyIncludedDestinations, subscriptionMapByLocalId, subscriptionMapByRemoteId
 
Constructor Summary
ConduitBridge(NetworkBridgeConfiguration configuration, 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.DemandForwardingBridgeSupport
addConsumerInfo, addRemoteBrokerToBrokerPath, addSubscription, appendToBrokerPath, appendToBrokerPath, configureDemandSubscription, configureMessage, contains, createDemandSubscription, createNetworkBridgeFilter, doCreateDemandSubscription, duplexStart, getControllingService, getDequeueCounter, getDurableDestinations, getDynamicallyIncludedDestinations, getEnqueueCounter, getExcludedDestinations, getLocalAddress, getLocalBroker, getLocalBrokerName, getLocalSubscriptionMap, getMbeanObjectName, getRegionSubscriptions, getRemoteAddress, getRemoteBroker, getRemoteBrokerName, getRemoteBrokerPath, getStaticallyIncludedDestinations, isCreatedByDuplex, isDuplex, isPermissableDestination, isPermissableDestination, removeDemandSubscriptionByLocalId, removeSubscription, safeWaitUntilStarted, serviceLocalCommand, serviceLocalException, serviceLocalException, serviceRemoteCommand, serviceRemoteException, setBrokerService, setCreatedByDuplex, setDurableDestinations, setDynamicallyIncludedDestinations, setExcludedDestinations, setMbeanObjectName, setNetworkBridgeListener, setStaticallyIncludedDestinations, setupStaticDestinations, start, startRemoteBridge, stop, triggerStartAsyncNetworkBridgeCreation
 
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 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 © 2005–2013 The Apache Software Foundation. All rights reserved.