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
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
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
 String toString()
           
 
Methods inherited from class org.apache.activemq.network.ConduitBridge
addToAlreadyInterestedConsumers, 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, getRegionSubscriptions, getRemoteAddress, getRemoteBroker, getRemoteBrokerName, getRemoteBrokerPath, getStaticallyIncludedDestinations, isCreatedByDuplex, isDuplex, isPermissableDestination, isPermissableDestination, removeDemandSubscriptionByLocalId, removeSubscription, safeWaitUntilStarted, serviceLocalCommand, serviceLocalException, serviceLocalException, serviceRemoteCommand, serviceRemoteException, setBrokerService, setCreatedByDuplex, setDurableDestinations, setDynamicallyIncludedDestinations, setExcludedDestinations, setMbeanObjectName, setNetworkBridgeListener, setStaticallyIncludedDestinations, start, startRemoteBridge, stop, triggerStartAsyncNetworkBridgeCreation
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

DurableConduitBridge

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

Parameters:
configuration -
localBroker -
remoteBroker -
Method Detail

toString

public String toString()
Overrides:
toString in class Object

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–2013 The Apache Software Foundation. All rights reserved.