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
bridgeFailed, brokerService, 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, getRegionSubscriptions, getRemoteAddress, getRemoteBroker, getRemoteBrokerName, getRemoteBrokerPath, getStaticallyIncludedDestinations, isCreatedByDuplex, isDuplex, isPermissableDestination, isPermissableDestination, removeDemandSubscription, removeDemandSubscriptionByLocalId, removeSubscription, safeWaitUntilStarted, serviceLocalCommand, serviceLocalException, serviceLocalException, 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

CompositeDemandForwardingBridge

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

serviceLocalBrokerInfo

protected void serviceLocalBrokerInfo(Command command)
                               throws InterruptedException
Throws:
InterruptedException


Copyright © 2005–2013 The Apache Software Foundation. All rights reserved.