org.apache.activemq.network
Class ConditionalNetworkBridgeFilterFactory

java.lang.Object
  extended by org.apache.activemq.network.ConditionalNetworkBridgeFilterFactory
All Implemented Interfaces:
NetworkBridgeFilterFactory

public class ConditionalNetworkBridgeFilterFactory
extends Object
implements NetworkBridgeFilterFactory

implement conditional behavior for queue consumers, allows replaying back to origin if no consumers are present on the local broker after a configurable delay, irrespective of the networkTTL Also allows rate limiting of messages through the network, useful for static includes


Constructor Summary
ConditionalNetworkBridgeFilterFactory()
           
 
Method Summary
 NetworkBridgeFilter create(ConsumerInfo info, BrokerId[] remoteBrokerPath, int networkTimeToLive)
           
 int getRateDuration()
           
 int getRateLimit()
           
 int getReplayDelay()
           
 boolean isReplayWhenNoConsumers()
           
 void setRateDuration(int rateDuration)
           
 void setRateLimit(int rateLimit)
           
 void setReplayDelay(int replayDelay)
           
 void setReplayWhenNoConsumers(boolean replayWhenNoConsumers)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

ConditionalNetworkBridgeFilterFactory

public ConditionalNetworkBridgeFilterFactory()
Method Detail

create

public NetworkBridgeFilter create(ConsumerInfo info,
                                  BrokerId[] remoteBrokerPath,
                                  int networkTimeToLive)
Specified by:
create in interface NetworkBridgeFilterFactory

setReplayWhenNoConsumers

public void setReplayWhenNoConsumers(boolean replayWhenNoConsumers)

isReplayWhenNoConsumers

public boolean isReplayWhenNoConsumers()

setRateLimit

public void setRateLimit(int rateLimit)

getRateLimit

public int getRateLimit()

getRateDuration

public int getRateDuration()

setRateDuration

public void setRateDuration(int rateDuration)

getReplayDelay

public int getReplayDelay()

setReplayDelay

public void setReplayDelay(int replayDelay)


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