org.apache.activemq.network
Class CompositeDemandForwardingBridge

java.lang.Object
  extended by org.apache.activemq.network.DemandForwardingBridgeSupport
      extended by org.apache.activemq.network.CompositeDemandForwardingBridge
All Implemented Interfaces:
BrokerServiceAware, NetworkBridge, Service

public class CompositeDemandForwardingBridge
extends DemandForwardingBridgeSupport

A demand forwarding bridge which works with multicast style transports where a single Transport could be communicating with multiple remote brokers


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
CompositeDemandForwardingBridge(NetworkBridgeConfiguration configuration, Transport localBroker, Transport remoteBroker)
           
 
Method Summary
protected  void serviceLocalBrokerInfo(Command command)
           
 
Methods inherited from class org.apache.activemq.network.DemandForwardingBridgeSupport
addConsumerInfo, addRemoteBrokerToBrokerPath, addSubscription, appendToBrokerPath, appendToBrokerPath, clearDownSubscriptions, configureDemandSubscription, configureMessage, contains, createDemandSubscription, createDemandSubscription, createNetworkBridgeFilter, doCreateDemandSubscription, duplexStart, getControllingService, getDequeueCounter, getDurableDestinations, getDynamicallyIncludedDestinations, getEnqueueCounter, getExcludedDestinations, getLocalAddress, getLocalBroker, getLocalBrokerName, getLocalSubscriptionMap, getMbeanObjectName, getRemoteAddress, getRemoteBroker, getRemoteBrokerName, getRemoteBrokerPath, getStaticallyIncludedDestinations, isCreatedByDuplex, isDuplex, isPermissableDestination, isPermissableDestination, removeDemandSubscription, removeDemandSubscriptionByLocalId, removeSubscription, 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

CompositeDemandForwardingBridge

public CompositeDemandForwardingBridge(NetworkBridgeConfiguration configuration,
                                       Transport localBroker,
                                       Transport remoteBroker)
Method Detail

serviceLocalBrokerInfo

protected void serviceLocalBrokerInfo(Command command)
                               throws java.lang.InterruptedException
Overrides:
serviceLocalBrokerInfo in class DemandForwardingBridgeSupport
Throws:
java.lang.InterruptedException


Copyright © 2005-2015. All Rights Reserved.