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

Field Summary

Fields inherited from class org.apache.activemq.network.DemandForwardingBridgeSupport

brokerInfoMutex, 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 boolean	checkPaths(BrokerId[] first, BrokerId[] second)
protected DemandSubscription	createDemandSubscription(ConsumerInfo info)
protected void	removeDemandSubscription(ConsumerId id)

Methods inherited from class org.apache.activemq.network.DemandForwardingBridgeSupport

addConsumerInfo, addRemoteBrokerToBrokerPath, addSubscription, appendToBrokerPath, appendToBrokerPath, clearDownSubscriptions, configureDemandSubscription, configureMessage, contains, createDemandSubscription, createNetworkBridgeFilter, doCreateDemandSubscription, duplexStart, getControllingService, getDequeueCounter, getDurableDestinations, getDynamicallyIncludedDestinations, getEnqueueCounter, getExcludedDestinations, getLocalAddress, getLocalBroker, getLocalBrokerName, getLocalSubscriptionMap, getMbeanObjectName, getRemoteAddress, getRemoteBroker, getRemoteBrokerName, getRemoteBrokerPath, getStaticallyIncludedDestinations, isCreatedByDuplex, isDuplex, isPermissableDestination, isPermissableDestination, removeDemandSubscriptionByLocalId, removeSubscription, serviceLocalBrokerInfo, serviceLocalCommand, serviceLocalException, serviceRemoteBrokerInfo, serviceRemoteCommand, serviceRemoteException, setBrokerService, setCreatedByDuplex, setDurableDestinations, setDynamicallyIncludedDestinations, setExcludedDestinations, setMbeanObjectName, setNetworkBridgeListener, setStaticallyIncludedDestinations, setupStaticDestinations, start, 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