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

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

All Implemented Interfaces:

PendingMessageLimitStrategy

public class ConstantPendingMessageLimitStrategy
extends java.lang.Object
implements PendingMessageLimitStrategy

This PendingMessageLimitStrategy is configured to a constant value for all subscriptions.

Constructor Summary

ConstantPendingMessageLimitStrategy()

Method Summary

int	getLimit()
int	getMaximumPendingMessageLimit(TopicSubscription subscription) Calculate the maximum number of pending messages (in excess of the prefetch size) for the given subscription
void	setLimit(int limit)

Methods inherited from class java.lang.Object

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

Constructor Detail

ConstantPendingMessageLimitStrategy

public ConstantPendingMessageLimitStrategy()

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

getLimit

public int getLimit()

setLimit

public void setLimit(int limit)