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

java.lang.Object
  extended by org.apache.activemq.broker.region.policy.PrefetchRatePendingMessageLimitStrategy
All Implemented Interfaces:
PendingMessageLimitStrategy

public class PrefetchRatePendingMessageLimitStrategy
extends 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.



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