GatewaySender
instead@Deprecated public class GatewayQueueAttributes extends Object
GatewayQueueAttributes
contains attributes
related to the Gateway
queue such as batch size and
disk directories.Modifier and Type | Field and Description |
---|---|
static int |
DEFAULT_ALERT_THRESHOLD
Deprecated.
The default alert threshold in milliseconds
|
static boolean |
DEFAULT_BATCH_CONFLATION
Deprecated.
The default batch conflation
|
static int |
DEFAULT_BATCH_SIZE
Deprecated.
The default batch size
|
static int |
DEFAULT_BATCH_TIME_INTERVAL
Deprecated.
The default batch time interval in milliseconds
|
static boolean |
DEFAULT_ENABLE_COMPACTION
Deprecated.
The default oplog compaction behaviour
|
static boolean |
DEFAULT_ENABLE_PERSISTENCE
Deprecated.
The default enable persistence
|
static boolean |
DEFAULT_ENABLE_ROLLING
Deprecated.
as of 6.5 use DEFAULT_ENABLE_COMPACTION instead.
|
static int |
DEFAULT_MAXIMUM_QUEUE_MEMORY
Deprecated.
The default maximum amount of memory (MB) to allow in the queue
before overflowing entries to disk
|
static String |
DEFAULT_OVERFLOW_DIRECTORY
Deprecated.
The default overflow directory
|
Constructor and Description |
---|
GatewayQueueAttributes()
Deprecated.
Default constructor.
|
GatewayQueueAttributes(String overflowDirectory,
int maximumQueueMemory,
int batchSize,
int batchTimeInterval,
boolean batchConflation,
boolean enablePersistence,
boolean enableCompaction,
int alertThreshold)
Deprecated.
use
GatewayQueueAttributes(String, int, int, int, boolean, boolean, int)
to specify a disk store name, rather than a directory name. |
GatewayQueueAttributes(String diskStoreName,
int maximumQueueMemory,
int batchSize,
int batchTimeInterval,
boolean batchConflation,
boolean enablePersistence,
int alertThreshold)
Deprecated.
Constructor.
|
Modifier and Type | Method and Description |
---|---|
int |
getAlertThreshold()
Deprecated.
Returns the alert threshold for entries in a
Gateway 's queue. |
boolean |
getBatchConflation()
Deprecated.
Answers whether to enable batch conflation for a
Gateway 's
queue. |
int |
getBatchSize()
Deprecated.
Answers the batch size for a
Gateway 's queue. |
int |
getBatchTimeInterval()
Deprecated.
Answers the batch time interval for a
Gateway 's queue. |
String |
getDiskStoreName()
Deprecated.
Gets the disk store name for overflow
|
boolean |
getEnablePersistence()
Deprecated.
Answers whether to enable persistence for a
Gateway 's
queue. |
int |
getMaximumQueueMemory()
Deprecated.
Answers maximum amount of memory (in MB) for a
Gateway 's
queue. |
String |
getOverflowDirectory()
Deprecated.
as of 6.5 use
getDiskStoreName() instead. |
boolean |
hasOverflowDirectory()
Deprecated.
as of 6.5 use
getDiskStoreName() instead. |
boolean |
isRollOplogs()
Deprecated.
as of 6.5 use
getDiskStoreName() instead.
On the disk store, use DiskStore.getAutoCompact() |
void |
setAlertThreshold(int threshold)
Deprecated.
Sets the alert threshold for entries in a
Gateway 's queue. |
void |
setBatchConflation(boolean batchConflation)
Deprecated.
Sets whether to enable batch conflation for a
Gateway 's
queue. |
void |
setBatchSize(int batchSize)
Deprecated.
Sets the batch size for a
Gateway 's queue. |
void |
setBatchTimeInterval(int batchTimeInterval)
Deprecated.
Sets the batch time interval for a
Gateway 's queue. |
void |
setDiskStoreName(String diskStoreName)
Deprecated.
Sets the disk store name for overflow
|
void |
setEnablePersistence(boolean enablePersistence)
Deprecated.
Sets whether to enable persistence for a
Gateway 's
queue. |
void |
setMaximumQueueMemory(int maximumQueueMemory)
Deprecated.
Sets the maximum amount of memory (in MB) for a
Gateway 's
queue. |
void |
setOverflowDirectory(String overflowDirectory)
Deprecated.
as of 6.5 use
setDiskStoreName(String) instead. |
void |
setRollOplogs(boolean rollingEnabled)
Deprecated.
as of 6.5 use
setDiskStoreName(String) instead.
When creating the disk store, use DiskStoreFactory.setAutoCompact(boolean) to
control compaction. |
public static final String DEFAULT_OVERFLOW_DIRECTORY
public static final int DEFAULT_MAXIMUM_QUEUE_MEMORY
public static final int DEFAULT_BATCH_SIZE
public static final int DEFAULT_BATCH_TIME_INTERVAL
public static final boolean DEFAULT_BATCH_CONFLATION
public static final boolean DEFAULT_ENABLE_PERSISTENCE
public static final boolean DEFAULT_ENABLE_COMPACTION
public static final boolean DEFAULT_ENABLE_ROLLING
public static final int DEFAULT_ALERT_THRESHOLD
public GatewayQueueAttributes()
public GatewayQueueAttributes(String overflowDirectory, int maximumQueueMemory, int batchSize, int batchTimeInterval, boolean batchConflation, boolean enablePersistence, boolean enableCompaction, int alertThreshold)
GatewayQueueAttributes(String, int, int, int, boolean, boolean, int)
to specify a disk store name, rather than a directory name.overflowDirectory
- The name of the directory in which to store
overflowed and/or persisted queue entries (if persistence is enabled)maximumQueueMemory
- The maximum heap memory to be used by the
queuebatchSize
- The batch size for messages sent between
Gateway
sbatchTimeInterval
- The maximum time interval in milliseconds
to wait before sending an incomplete batch of messages between
Gateway
sbatchConflation
- Whether to enable conflation for
batches of messages sent between Gateway
senablePersistence
- Whether to enable persistence for this
Gateway
's queueenableCompaction
- Whether to oplog compaction for this
Gateway
's queuealertThreshold
- The alert threshold in milliseconds for entries in
this Gateway
's queuepublic GatewayQueueAttributes(String diskStoreName, int maximumQueueMemory, int batchSize, int batchTimeInterval, boolean batchConflation, boolean enablePersistence, int alertThreshold)
diskStoreName
- The name of the disk store in which to store
overflowed and/or persisted queue entries (if persistence is enabled)maximumQueueMemory
- The maximum heap memory to be used by the
queuebatchSize
- The batch size for messages sent between
Gateway
sbatchTimeInterval
- The maximum time interval in milliseconds
to wait before sending an incomplete batch of messages between
Gateway
sbatchConflation
- Whether to enable conflation for
batches of messages sent between Gateway
senablePersistence
- Whether to enable persistence for this
Gateway
's queuealertThreshold
- The alert threshold in milliseconds for entries in
this Gateway
's queuepublic void setOverflowDirectory(String overflowDirectory)
setDiskStoreName(String)
instead.Gateway
queue's overflowed
and/or persisted queue entries.overflowDirectory
- the overflow directory for a Gateway
queue's overflowed and/or persisted queue entriespublic String getOverflowDirectory()
getDiskStoreName()
instead.Gateway
queue's
overflowed and/or persisted queue entries.Gateway
queue's
overflowed and/or persisted queue entriespublic void setDiskStoreName(String diskStoreName)
diskStoreName
- public String getDiskStoreName()
public void setMaximumQueueMemory(int maximumQueueMemory)
Gateway
's
queue.maximumQueueMemory
- The maximum amount of memory (in MB) for a
Gateway
's queue.public int getMaximumQueueMemory()
Gateway
's
queue.Gateway
's
queuepublic void setBatchSize(int batchSize)
Gateway
's queue.batchSize
- The size of batches sent from a Gateway
to its corresponding Gateway
.public int getBatchSize()
Gateway
's queue.Gateway
's queuepublic void setBatchTimeInterval(int batchTimeInterval)
Gateway
's queue.batchTimeInterval
- The maximum time interval that can elapse
before a partial batch is sent from a Gateway
to its corresponding Gateway
.public int getBatchTimeInterval()
Gateway
's queue.Gateway
's queuepublic void setBatchConflation(boolean batchConflation)
Gateway
's
queue.batchConflation
- Whether or not to enable batch conflation
for batches sent from a Gateway
to its corresponding
Gateway
.public boolean getBatchConflation()
Gateway
's
queue.Gateway
to its corresponding Gateway
.public void setEnablePersistence(boolean enablePersistence)
Gateway
's
queue.enablePersistence
- Whether to enable persistence for a
Gateway
's queuepublic boolean getEnablePersistence()
Gateway
's
queue.Gateway
's
queuepublic boolean isRollOplogs()
getDiskStoreName()
instead.
On the disk store, use DiskStore.getAutoCompact()
Gateway
's
queue.Gateway
's
queuepublic void setRollOplogs(boolean rollingEnabled)
setDiskStoreName(String)
instead.
When creating the disk store, use DiskStoreFactory.setAutoCompact(boolean)
to
control compaction.Gateway
's
queue.rollingEnabled
- Whether to enable oplog rolling for a
Gateway
's queuepublic void setAlertThreshold(int threshold)
Gateway
's queue.threshold
- the alert threshold for entries in a Gateway
's
queuepublic int getAlertThreshold()
Gateway
's queue.Gateway
's queuepublic boolean hasOverflowDirectory()
getDiskStoreName()
instead.true
if setOverflowDirectory(java.lang.String)
has been called.
Returns false
if the overflow directory has never been explicitly set.Copyright © 1997-2017 Pivotal Software, Inc. All rights reserved.