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

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

public class ConstantPendingMessageLimitStrategy
extends 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)


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