org.apache.activemq.network
Class ConditionalNetworkBridgeFilterFactory
java.lang.Object
org.apache.activemq.network.ConditionalNetworkBridgeFilterFactory
- All Implemented Interfaces:
- NetworkBridgeFilterFactory
public class ConditionalNetworkBridgeFilterFactory
- extends java.lang.Object
- implements NetworkBridgeFilterFactory
implement conditional behaviour 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
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
ConditionalNetworkBridgeFilterFactory
public ConditionalNetworkBridgeFilterFactory()
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-2016. All Rights Reserved.