mirror of https://github.com/apache/activemq.git
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@696755 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
a2101b7b05
commit
bca3d9e9d9
|
@ -39,9 +39,13 @@ import org.apache.activemq.memory.list.SimpleMessageList;
|
||||||
public class FixedSizedSubscriptionRecoveryPolicy implements SubscriptionRecoveryPolicy {
|
public class FixedSizedSubscriptionRecoveryPolicy implements SubscriptionRecoveryPolicy {
|
||||||
|
|
||||||
private MessageList buffer;
|
private MessageList buffer;
|
||||||
private int maximumSize = 100 * 64 * 1024;
|
private int maximumSize = 64 * 1024;
|
||||||
private boolean useSharedBuffer = true;
|
private boolean useSharedBuffer = true;
|
||||||
|
|
||||||
|
public FixedSizedSubscriptionRecoveryPolicy() {
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
public SubscriptionRecoveryPolicy copy() {
|
public SubscriptionRecoveryPolicy copy() {
|
||||||
FixedSizedSubscriptionRecoveryPolicy rc = new FixedSizedSubscriptionRecoveryPolicy();
|
FixedSizedSubscriptionRecoveryPolicy rc = new FixedSizedSubscriptionRecoveryPolicy();
|
||||||
rc.setMaximumSize(maximumSize);
|
rc.setMaximumSize(maximumSize);
|
||||||
|
|
Loading…
Reference in New Issue