org.apache.activemq.network
Class DurableConduitBridge

java.lang.Object
  org.apache.activemq.network.DemandForwardingBridgeSupport
      org.apache.activemq.network.DemandForwardingBridge
          org.apache.activemq.network.ConduitBridge
              org.apache.activemq.network.DurableConduitBridge

All Implemented Interfaces:

BrokerServiceAware, NetworkBridge, Service

public class DurableConduitBridge
extends ConduitBridge

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

DurableConduitBridge(NetworkBridgeConfiguration configuration, Transport localBroker, Transport remoteBroker)
Constructor

Method Summary

protected DemandSubscription	createDemandSubscription(ConsumerInfo info)
protected boolean	doesConsumerExist(ActiveMQDestination dest)
protected java.lang.String	getSubscriberName(ActiveMQDestination dest)
protected void	setupStaticDestinations() Subscriptions for these destinations are always created

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

addToAlreadyInterestedConsumers, checkPaths, removeDemandSubscription

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, 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

DurableConduitBridge

public DurableConduitBridge(NetworkBridgeConfiguration configuration,
                            Transport localBroker,
                            Transport remoteBroker)

Constructor

Parameters:

configuration -

localBroker -

remoteBroker -

Method Detail

setupStaticDestinations

protected void setupStaticDestinations()

Subscriptions for these destinations are always created

Overrides:

setupStaticDestinations in class DemandForwardingBridgeSupport

createDemandSubscription

protected DemandSubscription createDemandSubscription(ConsumerInfo info)
                                               throws java.io.IOException

Overrides:

createDemandSubscription in class ConduitBridge

Throws:

java.io.IOException

getSubscriberName

protected java.lang.String getSubscriberName(ActiveMQDestination dest)

doesConsumerExist

protected boolean doesConsumerExist(ActiveMQDestination dest)