org.apache.activemq.network
Class DurableConduitBridge

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

public class DurableConduitBridge
extends ConduitBridge

Consolidates subscriptions


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
DurableConduitBridge(NetworkBridgeConfiguration configuration, Transport localBroker, Transport remoteBroker)
          Constructor
 
Method Summary
protected  DemandSubscription createDemandSubscription(ConsumerInfo info)
           
protected  boolean doesConsumerExist(ActiveMQDestination dest)
           
protected  String getSubscriberName(ActiveMQDestination dest)
           
protected  void setupStaticDestinations()
          Subscriptions for these destinations are always created
 
Methods inherited from class org.apache.activemq.network.ConduitBridge
addToAlreadyInterestedConsumers, checkPaths, removeDemandSubscription
 
Methods inherited from class org.apache.activemq.network.DemandForwardingBridgeSupport
addConsumerInfo, addRemoteBrokerToBrokerPath, addSubscription, appendToBrokerPath, appendToBrokerPath, configureDemandSubscription, configureMessage, contains, createDemandSubscription, createNetworkBridgeFilter, doCreateDemandSubscription, duplexStart, getControllingService, getDequeueCounter, getDurableDestinations, getDynamicallyIncludedDestinations, getEnqueueCounter, getExcludedDestinations, getLocalAddress, getLocalBroker, getLocalBrokerName, getLocalSubscriptionMap, getMbeanObjectName, getRemoteAddress, getRemoteBroker, getRemoteBrokerName, getRemoteBrokerPath, getStaticallyIncludedDestinations, isCreatedByDuplex, isDuplex, isPermissableDestination, isPermissableDestination, removeDemandSubscriptionByLocalId, removeSubscription, safeWaitUntilStarted, serviceLocalBrokerInfo, serviceLocalCommand, serviceLocalException, serviceRemoteBrokerInfo, serviceRemoteCommand, serviceRemoteException, setBrokerService, setCreatedByDuplex, setDurableDestinations, setDynamicallyIncludedDestinations, setExcludedDestinations, setMbeanObjectName, setNetworkBridgeListener, setStaticallyIncludedDestinations, 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

DurableConduitBridge

public DurableConduitBridge(NetworkBridgeConfiguration configuration,
                            Transport localBroker,
                            Transport remoteBroker)
Constructor

Parameters:
configuration -
localBroker -
remoteBroker -
Method Detail

setupStaticDestinations

protected void setupStaticDestinations()
Subscriptions for these destinations are always created

Overrides:
setupStaticDestinations in class DemandForwardingBridgeSupport

createDemandSubscription

protected DemandSubscription createDemandSubscription(ConsumerInfo info)
                                               throws IOException
Overrides:
createDemandSubscription in class ConduitBridge
Throws:
IOException

getSubscriberName

protected String getSubscriberName(ActiveMQDestination dest)

doesConsumerExist

protected boolean doesConsumerExist(ActiveMQDestination dest)


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