public class PrefetchRatePendingMessageLimitStrategy extends java.lang.Object implements PendingMessageLimitStrategy
| Constructor and Description |
|---|
PrefetchRatePendingMessageLimitStrategy() |
| Modifier and Type | Method and Description |
|---|---|
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.
|
public PrefetchRatePendingMessageLimitStrategy()
public int getMaximumPendingMessageLimit(TopicSubscription subscription)
PendingMessageLimitStrategygetMaximumPendingMessageLimit in interface PendingMessageLimitStrategypublic double getMultiplier()
public void setMultiplier(double rate)
Copyright © 2005-2013 Red Hat, Inc.. All Rights Reserved.