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

Constructor Summary

Constructors

Constructor and Description
ConditionalNetworkBridgeFilterFactory()

Method Summary

Methods

Modifier and Type	Method and Description
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)