public interface GatewaySender
Modifier and Type | Field and Description |
---|---|
static int |
CONNECTION_RETRY_INTERVAL
Retry a connection from sender to receiver after specified time interval (in milliseconds)
in case receiver is not up and running.
|
static int |
DEFAULT_ALERT_THRESHOLD
The default alert threshold in milliseconds
|
static boolean |
DEFAULT_BATCH_CONFLATION
The default batch conflation
|
static int |
DEFAULT_BATCH_SIZE
The default batch size
|
static int |
DEFAULT_BATCH_TIME_INTERVAL
The default batch time interval in milliseconds
|
static boolean |
DEFAULT_DISK_SYNCHRONOUS
The default value ( true) for writing to disk synchronously in case
of persistence.
|
static int |
DEFAULT_DISPATCHER_THREADS |
static int |
DEFAULT_DISTRIBUTED_SYSTEM_ID |
static boolean |
DEFAULT_IS_FOR_INTERNAL_USE |
static boolean |
DEFAULT_IS_PARALLEL |
static boolean |
DEFAULT_MANUAL_START
The default value (false) for manually starting a
GatewaySender . |
static int |
DEFAULT_MAXIMUM_QUEUE_MEMORY
The default maximum amount of memory (MB) to allow in the queue before
overflowing entries to disk
|
static Gateway.OrderPolicy |
DEFAULT_ORDER_POLICY |
static int |
DEFAULT_PARALLELISM_REPLICATED_REGION |
static boolean |
DEFAULT_PERSISTENCE_ENABLED
The default value (false)of whether to persist queue data to disk or not.
|
static int |
DEFAULT_SOCKET_BUFFER_SIZE
The default buffer size for socket buffers from a sending GatewaySender to
its receiving
GatewayReceiver . |
static int |
DEFAULT_SOCKET_READ_TIMEOUT
The default amount of time in milliseconds that a socket read between a
sending
Gateway and its receiving Gateway will
block. |
static boolean |
EARLY_ACK |
static int |
GATEWAY_CONNECTION_IDLE_TIMEOUT |
static String |
GATEWAY_CONNECTION_READ_TIMEOUT_PROPERTY
The obsolete socket read timeout java system property.
|
static long |
GATEWAY_SENDER_TIMEOUT
Time, in seconds, that we allow before a
GatewaySender is considered
dead and should be aborted |
static long |
MAXIMUM_BATCH_SIZE_IN_BYTES
Maximum batch size in bytes.
|
static long |
MAXIMUM_BATCH_SIZE_IN_BYTES_LIMIT
Maximum batch size in bytes limit.
|
static int |
MINIMUM_SOCKET_READ_TIMEOUT
The default minimum socket read timeout.
|
static int |
QUEUE_OPLOG_SIZE
Size of the oplog file used for the persistent queue in bytes
|
static boolean |
REMOVE_FROM_QUEUE_ON_EXCEPTION
If the System property is set, use it.
|
Modifier and Type | Method and Description |
---|---|
void |
addGatewayEventFilter(GatewayEventFilter filter)
Adds the provided
GatewayEventFilter to this GatewaySender. |
int |
getAlertThreshold()
Returns the alert threshold in milliseconds for entries in a GatewaySender's queue.
|
int |
getBatchSize()
Returns the batch size for this GatewaySender.
|
int |
getBatchTimeInterval()
Returns the batch time interval for this GatewaySender.
|
String |
getDiskStoreName()
Gets the disk store name for overflow or persistence.
|
int |
getDispatcherThreads()
Returns the number of dispatcher threads working for this
GatewaySender . |
List<GatewayEventFilter> |
getGatewayEventFilters()
Returns the list of
GatewayEventFilter added to this
GatewaySender. |
GatewayEventSubstitutionFilter |
getGatewayEventSubstitutionFilter()
Returns this
GatewaySender's GatewayEventSubstitutionFilter . |
List<GatewayTransportFilter> |
getGatewayTransportFilters()
Returns the list of
GatewayTransportFilter added to this
GatewaySender. |
String |
getId()
Returns the id of this GatewaySender.
|
int |
getMaximumQueueMemory()
Returns the maximum amount of memory (in MB) for a GatewaySender's queue.
|
int |
getMaxParallelismForReplicatedRegion() |
Gateway.OrderPolicy |
getOrderPolicy()
Returns the order policy followed while dispatching the events to remote ds.
|
int |
getRemoteDSId()
Returns the id of the remote
GatewayReceiver 's
DistributedSystem. |
int |
getSocketBufferSize()
Returns the configured buffer size of the socket connection between this
GatewaySender and its receiving
GatewayReceiver . |
int |
getSocketReadTimeout()
Returns the amount of time in milliseconds that a socket read between a
sending GatewaySender and its receiving
GatewayReceiver will
block. |
boolean |
isBatchConflationEnabled()
Answers whether to enable batch conflation for a GatewaySender 's queue.
|
boolean |
isDiskSynchronous()
Returns isDiskSynchronous boolean property for this GatewaySender.
|
boolean |
isManualStart()
Returns the manual start boolean property for this GatewaySender.
|
boolean |
isParallel()
Returns isParallel boolean property for this GatewaySender.
|
boolean |
isPaused()
Returns whether or not this GatewaySender is paused.
|
boolean |
isPersistenceEnabled()
Returns true if persistence is enabled for this GatewaySender, otherwise
returns false.
|
boolean |
isRunning()
Returns whether or not this GatewaySender is running.
|
void |
pause()
Pauses the dispatching of the events from the underlying queue.
|
void |
rebalance()
Rebalances this GatewaySender.
|
void |
removeGatewayEventFilter(GatewayEventFilter filter)
Removes the provided
GatewayEventFilter from this
GatewaySender. |
void |
resume()
Resumes this paused GatewaySender.
|
void |
start()
Starts this GatewaySender.
|
void |
stop()
Stops this GatewaySender.
|
static final boolean DEFAULT_MANUAL_START
GatewaySender
.static final boolean DEFAULT_DISK_SYNCHRONOUS
static final int DEFAULT_SOCKET_BUFFER_SIZE
GatewayReceiver
.static final int DEFAULT_SOCKET_READ_TIMEOUT
Gateway
and its receiving Gateway
will
block.static final int MINIMUM_SOCKET_READ_TIMEOUT
static final int QUEUE_OPLOG_SIZE
static final boolean DEFAULT_PERSISTENCE_ENABLED
static final boolean DEFAULT_BATCH_CONFLATION
static final int DEFAULT_BATCH_SIZE
static final int DEFAULT_BATCH_TIME_INTERVAL
static final int DEFAULT_ALERT_THRESHOLD
static final int DEFAULT_PARALLELISM_REPLICATED_REGION
static final int DEFAULT_DISTRIBUTED_SYSTEM_ID
static final int DEFAULT_DISPATCHER_THREADS
static final Gateway.OrderPolicy DEFAULT_ORDER_POLICY
static final int DEFAULT_MAXIMUM_QUEUE_MEMORY
static final long GATEWAY_SENDER_TIMEOUT
GatewaySender is considered
dead and should be aborted
static final String GATEWAY_CONNECTION_READ_TIMEOUT_PROPERTY
static final int GATEWAY_CONNECTION_IDLE_TIMEOUT
static final boolean REMOVE_FROM_QUEUE_ON_EXCEPTION
static final boolean EARLY_ACK
static final boolean DEFAULT_IS_PARALLEL
static final boolean DEFAULT_IS_FOR_INTERNAL_USE
static final int CONNECTION_RETRY_INTERVAL
static final long MAXIMUM_BATCH_SIZE_IN_BYTES
static final long MAXIMUM_BATCH_SIZE_IN_BYTES_LIMIT
void start()
void stop()
isParallel()
void pause()
isParallel()
,
getBatchSize()
,
resume()
void resume()
void rebalance()
boolean isRunning()
boolean isPaused()
void addGatewayEventFilter(GatewayEventFilter filter)
GatewayEventFilter
to this GatewaySender.filter
- void removeGatewayEventFilter(GatewayEventFilter filter)
GatewayEventFilter
from this
GatewaySender.filter
- GatewayEventSubstitutionFilter getGatewayEventSubstitutionFilter()
GatewaySender's
GatewayEventSubstitutionFilter
.GatewaySender's
GatewayEventSubstitutionFilter
String getId()
int getRemoteDSId()
GatewayReceiver
's
DistributedSystem.GatewayReceiver
's
DistributedSystem.int getSocketBufferSize()
GatewayReceiver
. The default
is 32768 bytes.GatewayReceiver
int getSocketReadTimeout()
GatewayReceiver
will
block.
The default value is 0 which is interpreted as infinite timeout.GatewayReceiver
will blockString getDiskStoreName()
int getMaximumQueueMemory()
int getBatchSize()
int getBatchTimeInterval()
boolean isBatchConflationEnabled()
GatewayReceiver
.boolean isPersistenceEnabled()
int getAlertThreshold()
List<GatewayEventFilter> getGatewayEventFilters()
GatewayEventFilter
added to this
GatewaySender.GatewayEventFilter
added to this
GatewaySender.List<GatewayTransportFilter> getGatewayTransportFilters()
GatewayTransportFilter
added to this
GatewaySender.GatewayTransportFilter
added to this
GatewaySender.boolean isDiskSynchronous()
boolean isManualStart()
boolean isParallel()
int getDispatcherThreads()
GatewaySender
.
Default number of dispatcher threads is 5.GatewaySender
Gateway.OrderPolicy getOrderPolicy()
int getMaxParallelismForReplicatedRegion()
Copyright © 1997-2017 Pivotal Software, Inc. All rights reserved.