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

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

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
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, 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, safeWaitUntilStarted, serviceLocalCommand, serviceLocalException, serviceLocalException, serviceRemoteCommand, serviceRemoteException, setBrokerService, setCreatedByDuplex, setDurableDestinations, setDynamicallyIncludedDestinations, setExcludedDestinations, setMbeanObjectName, setNetworkBridgeListener, setStaticallyIncludedDestinations, start, startRemoteBridge, stop, triggerStartAsyncNetworkBridgeCreation

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)