public class ConstantPendingMessageLimitStrategy extends Object implements PendingMessageLimitStrategy
Constructor and Description |
---|
ConstantPendingMessageLimitStrategy() |
Modifier and Type | Method and Description |
---|---|
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) |
public int getMaximumPendingMessageLimit(TopicSubscription subscription)
PendingMessageLimitStrategy
getMaximumPendingMessageLimit
in interface PendingMessageLimitStrategy
public int getLimit()
public void setLimit(int limit)
Copyright © 2005–2015 The Apache Software Foundation. All rights reserved.