1 18 package org.apache.activemq.broker.region.policy; 19 20 import org.apache.activemq.broker.region.TopicSubscription; 21 22 30 public class PrefetchRatePendingMessageLimitStrategy implements PendingMessageLimitStrategy { 31 32 private double multiplier = 0.5; 33 34 public int getMaximumPendingMessageLimit(TopicSubscription subscription) { 35 int prefetchSize = subscription.getConsumerInfo().getPrefetchSize(); 36 return (int) (prefetchSize * multiplier); 37 } 38 39 public double getMultiplier() { 40 return multiplier; 41 } 42 43 47 public void setMultiplier(double rate) { 48 this.multiplier = rate; 49 } 50 51 } 52 | Popular Tags |