Package org.apache.activemq.network

Class DemandForwardingBridge

java.lang.Object

org.apache.activemq.network.DemandForwardingBridgeSupport

org.apache.activemq.network.DemandForwardingBridge

All Implemented Interfaces:

BrokerServiceAware, NetworkBridge, Service

Direct Known Subclasses:

ConduitBridge

public class DemandForwardingBridge
extends DemandForwardingBridgeSupport

Forwards messages from the local broker to the remote broker based on demand.

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
DemandForwardingBridge(NetworkBridgeConfiguration configuration, Transport localBroker, Transport remoteBroker)

Method Summary

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

addConsumerInfo, addProxyNetworkSubscriptionBrokerPath, addProxyNetworkSubscriptionClientId, addRemoteBrokerToBrokerPath, addSubscription, appendToBrokerPath, appendToBrokerPath, canDuplexDispatch, configureConsumerPrefetch, configureDemandSubscription, configureMessage, contains, createDemandSubscription, 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, removeDemandSubscription, 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

DemandForwardingBridge

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