public class PrefetchRatePendingMessageLimitStrategy extends 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)
PendingMessageLimitStrategy
getMaximumPendingMessageLimit
in interface PendingMessageLimitStrategy
public double getMultiplier()
public void setMultiplier(double rate)
Copyright © 2005–2015. All rights reserved.