public class PersistentSubscriptionSettings
extends java.lang.Object
| Constructor and Description |
|---|
PersistentSubscriptionSettings(int checkpointAfterMs,
boolean extraStatistics,
boolean resolveLinks,
int historyBufferSize,
int liveBufferSize,
int maxCheckpointCount,
int maxRetryCount,
int maxSubscriberCount,
int messageTimeoutMs,
int minCheckpointCount,
int readBatchSize,
long revision,
ConsumerStrategy strategy) |
| Modifier and Type | Method and Description |
|---|---|
static PersistentSubscriptionSettingsBuilder |
builder() |
static PersistentSubscriptionSettingsBuilder |
copy(PersistentSubscriptionSettings settings) |
int |
getCheckpointAfterMs() |
int |
getHistoryBufferSize() |
int |
getLiveBufferSize() |
int |
getMaxCheckpointCount() |
int |
getMaxRetryCount() |
int |
getMaxSubscriberCount() |
int |
getMessageTimeoutMs() |
int |
getMinCheckpointCount() |
int |
getReadBatchSize() |
long |
getRevision() |
ConsumerStrategy |
getStrategy() |
boolean |
isExtraStatistics() |
boolean |
isResolveLinks() |
public PersistentSubscriptionSettings(int checkpointAfterMs,
boolean extraStatistics,
boolean resolveLinks,
int historyBufferSize,
int liveBufferSize,
int maxCheckpointCount,
int maxRetryCount,
int maxSubscriberCount,
int messageTimeoutMs,
int minCheckpointCount,
int readBatchSize,
long revision,
ConsumerStrategy strategy)
public static PersistentSubscriptionSettingsBuilder builder()
public static PersistentSubscriptionSettingsBuilder copy(PersistentSubscriptionSettings settings)
public int getCheckpointAfterMs()
public boolean isExtraStatistics()
public boolean isResolveLinks()
public int getHistoryBufferSize()
public int getLiveBufferSize()
public int getMaxCheckpointCount()
public int getMaxRetryCount()
public int getMaxSubscriberCount()
public int getMessageTimeoutMs()
public int getMinCheckpointCount()
public int getReadBatchSize()
public long getRevision()
public ConsumerStrategy getStrategy()