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, 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, safeWaitUntilStarted, serviceLocalCommand, serviceLocalException, serviceRemoteBrokerInfo, serviceRemoteCommand, serviceRemoteException, setBrokerService, setCreatedByDuplex, setDurableDestinations, setDynamicallyIncludedDestinations, setExcludedDestinations, setMbeanObjectName, setNetworkBridgeListener, setStaticallyIncludedDestinations, setupStaticDestinations, start, startRemoteBridge, stop, triggerLocalStartBridge, triggerRemoteStartBridge
 
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 InterruptedException
Overrides:
serviceLocalBrokerInfo in class DemandForwardingBridgeSupport
Throws:
InterruptedException


Copyright © 2005-2012 The Apache Software Foundation. All Rights Reserved.