Package 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

bridgeFailed, brokerService, configuration, consumerIdGenerator, defaultFilterFactory, demandConsumerDispatched, demandConsumerInfo, disposed, DURABLE_SUB_PREFIX, durableDestinations, dynamicallyIncludedDestinations, excludedDestinations, forcedDurableRemoteId, idGenerator, lastConnectSucceeded, localBridgeStarted, localBroker, localBrokerId, localBrokerPath, localClientId, localConnectionInfo, localSessionInfo, localStartedLatch, networkBridgeStatistics, producerInfo, remoteBridgeStarted, remoteBroker, remoteBrokerId, remoteBrokerName, remoteBrokerPath, remoteConnectionInfo, startedLatch, staticallyIncludedDestinations, staticDestinationsLatch, subscriptionMapByLocalId, subscriptionMapByRemoteId

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
protected boolean	addToAlreadyInterestedConsumers(ConsumerInfo info, boolean isForcedDurable)
protected DemandSubscription	createDemandSubscription(ConsumerInfo info)
protected void	removeDemandSubscription(ConsumerId id)

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

addConsumerInfo, addProxyNetworkSubscriptionBrokerPath, addProxyNetworkSubscriptionClientId, addRemoteBrokerToBrokerPath, addSubscription, appendToBrokerPath, appendToBrokerPath, canDuplexDispatch, configureConsumerPrefetch, configureDemandSubscription, configureMessage, contains, createDemandSubscription, createNetworkBridgeFilter, doCreateDemandSubscription, duplexStart, getControllingService, getDequeueCounter, getDurableDestinations, getDynamicallyIncludedDestinations, getEnqueueCounter, getExcludedDestinations, getLocalAddress, getLocalBroker, getLocalBrokerName, getLocalSubscriptionMap, getMbeanObjectName, getNetworkBridgeStatistics, getRegionSubscriptions, getRemoteAddress, getRemoteBroker, getRemoteBrokerId, getRemoteBrokerName, getRemoteBrokerPath, getStaticallyIncludedDestinations, getStoredSequenceIdForMessage, isCreatedByDuplex, isDirectBridgeConsumer, isDuplex, isPermissableDestination, isPermissableDestination, isProxyBridgeSubscription, isProxyNSConsumerBrokerPath, isProxyNSConsumerClientId, removeDemandSubscriptionByLocalId, removeSubscription, resetStats, safeWaitUntilStarted, serviceInboundMessage, serviceLocalCommand, serviceLocalException, serviceLocalException, serviceOutbound, 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,
                                                  boolean isForcedDurable)

removeDemandSubscription

protected void removeDemandSubscription(ConsumerId id)
                                 throws IOException

Overrides:

removeDemandSubscription in class DemandForwardingBridgeSupport

Throws:

IOException