org.apache.activemq.broker.region.policy
Class PrefetchRatePendingMessageLimitStrategy

java.lang.Object
  org.apache.activemq.broker.region.policy.PrefetchRatePendingMessageLimitStrategy

All Implemented Interfaces:

PendingMessageLimitStrategy

public class PrefetchRatePendingMessageLimitStrategy
extends java.lang.Object
implements PendingMessageLimitStrategy

This PendingMessageLimitStrategy sets the maximum pending message limit value to be a multiplier of the prefetch limit of the subscription.

Constructor Summary

PrefetchRatePendingMessageLimitStrategy()

Method Summary

int	getMaximumPendingMessageLimit(TopicSubscription subscription) Calculate the maximum number of pending messages (in excess of the prefetch size) for the given subscription
double	getMultiplier()
void	setMultiplier(double rate) Sets the multiplier of the prefetch size which will be used to define the maximum number of pending messages for non-durable topics before messages are discarded.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

PrefetchRatePendingMessageLimitStrategy

public PrefetchRatePendingMessageLimitStrategy()

Method Detail

getMaximumPendingMessageLimit

public int getMaximumPendingMessageLimit(TopicSubscription subscription)

Description copied from interface: PendingMessageLimitStrategy

Calculate the maximum number of pending messages (in excess of the prefetch size) for the given subscription

Specified by:

getMaximumPendingMessageLimit in interface PendingMessageLimitStrategy

Returns:

the maximum or -1 if there is no maximum

getMultiplier

public double getMultiplier()

setMultiplier

public void setMultiplier(double rate)

Sets the multiplier of the prefetch size which will be used to define the maximum number of pending messages for non-durable topics before messages are discarded.