public static class ReplicationQueue.ReplicationQueueSettings
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
long |
batchInterval |
long |
batchIntervalError |
int |
batchSize |
static long |
DEFAULT_BATCH_INTERVAL |
static long |
DEFAULT_BATCH_INTERVAL_ERROR |
static int |
DEFAULT_BATCH_SIZE |
static int |
DEFAULT_QUEUE_FILE_MAX_SIZE |
static int |
DEFAULT_QUEUE_MAX_SIZE |
static com.streamscape.ds.persist.jfq.FileQueueTransactionFilePersistent.TransactionPersistentType |
DEFAULT_TRANSACTION_PERSISTENCE_TYPE |
static int |
DEFAULT_WRITE_BUFFER_SIZE |
static long |
DEFAULT_WRITE_FLUSH_DELAY |
long |
queueFileMaxFileSize |
long |
queueFileWriteBufferSize |
long |
queueFileWriteFlushDelay |
long |
queueMaxSize |
com.streamscape.ds.persist.jfq.FileQueueTransactionFilePersistent.TransactionPersistentType |
transactionPersistenceType |
ReplicationQueue.QueueType |
type |
Constructor and Description |
---|
ReplicationQueueSettings() |
ReplicationQueueSettings(ReplicationQueue.ReplicationQueueSettings settings) |
Modifier and Type | Method and Description |
---|---|
void |
initWithDefaults() |
void |
mergeFrom(ReplicationQueue.ReplicationQueueSettings from) |
public static final int DEFAULT_BATCH_SIZE
public static final int DEFAULT_QUEUE_MAX_SIZE
public static final long DEFAULT_BATCH_INTERVAL
public static final long DEFAULT_BATCH_INTERVAL_ERROR
public static final int DEFAULT_QUEUE_FILE_MAX_SIZE
public static final int DEFAULT_WRITE_BUFFER_SIZE
public static final long DEFAULT_WRITE_FLUSH_DELAY
public static final com.streamscape.ds.persist.jfq.FileQueueTransactionFilePersistent.TransactionPersistentType DEFAULT_TRANSACTION_PERSISTENCE_TYPE
public ReplicationQueue.QueueType type
public int batchSize
public long batchInterval
public long batchIntervalError
public long queueMaxSize
public long queueFileMaxFileSize
public long queueFileWriteBufferSize
public long queueFileWriteFlushDelay
public com.streamscape.ds.persist.jfq.FileQueueTransactionFilePersistent.TransactionPersistentType transactionPersistenceType
public ReplicationQueueSettings()
public ReplicationQueueSettings(ReplicationQueue.ReplicationQueueSettings settings)
public void initWithDefaults()
public void mergeFrom(ReplicationQueue.ReplicationQueueSettings from)
Copyright © 2015-2024 StreamScape Technologies. All rights reserved.