com.gemstone.gemfire.cache.wan
Interface GatewaySender

public interface GatewaySender

Since:

7.0

Field Summary

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 GatewayHub.
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 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 int	GATEWAY_CONNECTION_READ_TIMEOUT
static long	GATEWAY_SENDER_TIMEOUT Time, in seconds, that we allow before a GatewaySender is considered dead and should be aborted
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.

Method Summary

void	addGatewayEventFilter(GatewayEventFilter filter) Adds the provided GatewayEventFilter to this GatewaySender.
int	getAlertThreshold() Returns the alert threshold 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.
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.
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 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.

Field Detail

DEFAULT_MANUAL_START

static final boolean DEFAULT_MANUAL_START

The default value (false) for manually starting a GatewayHub.

See Also:

Constant Field Values

DEFAULT_DISK_SYNCHRONOUS

static final boolean DEFAULT_DISK_SYNCHRONOUS

The default value ( true) for writing to disk synchronously in case of persistence.

See Also:

Constant Field Values

DEFAULT_SOCKET_BUFFER_SIZE

static final int DEFAULT_SOCKET_BUFFER_SIZE

The default buffer size for socket buffers from a sending GatewaySender to its receiving GatewayReceiver.

See Also:

Constant Field Values

DEFAULT_SOCKET_READ_TIMEOUT

static final 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.

QUEUE_OPLOG_SIZE

static final int QUEUE_OPLOG_SIZE

Size of the oplog file used for the persistent queue in bytes

DEFAULT_PERSISTENCE_ENABLED

static final boolean DEFAULT_PERSISTENCE_ENABLED

The default value (false)of whether to persist queue data to disk or not.

See Also:

Constant Field Values

DEFAULT_BATCH_CONFLATION

static final boolean DEFAULT_BATCH_CONFLATION

The default batch conflation

See Also:

Constant Field Values

DEFAULT_BATCH_SIZE

static final int DEFAULT_BATCH_SIZE

The default batch size

See Also:

Constant Field Values

DEFAULT_BATCH_TIME_INTERVAL

static final int DEFAULT_BATCH_TIME_INTERVAL

The default batch time interval in milliseconds

See Also:

Constant Field Values

DEFAULT_ALERT_THRESHOLD

static final int DEFAULT_ALERT_THRESHOLD

The default alert threshold in milliseconds

See Also:

Constant Field Values

DEFAULT_DISTRIBUTED_SYSTEM_ID

static final int DEFAULT_DISTRIBUTED_SYSTEM_ID

See Also:

Constant Field Values

DEFAULT_DISPATCHER_THREADS

static final int DEFAULT_DISPATCHER_THREADS

See Also:

Constant Field Values

DEFAULT_ORDER_POLICY

static final Gateway.OrderPolicy DEFAULT_ORDER_POLICY

DEFAULT_MAXIMUM_QUEUE_MEMORY

static final int DEFAULT_MAXIMUM_QUEUE_MEMORY

The default maximum amount of memory (MB) to allow in the queue before overflowing entries to disk

See Also:

Constant Field Values

GATEWAY_SENDER_TIMEOUT

static final long GATEWAY_SENDER_TIMEOUT

Time, in seconds, that we allow before a GatewaySender is considered dead and should be aborted

GATEWAY_CONNECTION_READ_TIMEOUT

static final int GATEWAY_CONNECTION_READ_TIMEOUT

GATEWAY_CONNECTION_IDLE_TIMEOUT

static final int GATEWAY_CONNECTION_IDLE_TIMEOUT

REMOVE_FROM_QUEUE_ON_EXCEPTION

static final boolean REMOVE_FROM_QUEUE_ON_EXCEPTION

If the System property is set, use it. Otherwise, set default to 'true'.

EARLY_ACK

static final boolean EARLY_ACK

DEFAULT_IS_PARALLEL

static final boolean DEFAULT_IS_PARALLEL

See Also:

Constant Field Values

DEFAULT_IS_FOR_INTERNAL_USE

static final boolean DEFAULT_IS_FOR_INTERNAL_USE

See Also:

Constant Field Values

Method Detail

start

void start()

Starts this GatewaySender. Once the GatewaySender is running, its configuration cannot be changed.

stop

void stop()

Stops this GatewaySender.

pause

void pause()

Pauses this GatewaySender.

resume

void resume()

Resumes this paused GatewaySender.

isRunning

boolean isRunning()

Returns whether or not this GatewaySender is running.

isPaused

boolean isPaused()

Returns whether or not this GatewaySender is paused.

addGatewayEventFilter

void addGatewayEventFilter(GatewayEventFilter filter)

Adds the provided GatewayEventFilter to this GatewaySender.

Parameters:

filter -

removeGatewayEventFilter

void removeGatewayEventFilter(GatewayEventFilter filter)

Removes the provided GatewayEventFilter from this GatewaySender.

Parameters:

filter -

getId

String getId()

Returns the id of this GatewaySender.

Returns:

the id of this GatewaySender.

getRemoteDSId

int getRemoteDSId()

Returns the id of the remote GatewayReceiver's DistributedSystem.

Returns:

the id of the remote GatewayReceiver's DistributedSystem.

getSocketBufferSize

int getSocketBufferSize()

Returns the configured buffer size of the socket connection between this GatewaySender and its receiving GatewayReceiver. The default is 32768 bytes.

Returns:

the configured buffer size of the socket connection between this GatewaySender and its receiving GatewayReceiver

getSocketReadTimeout

int getSocketReadTimeout()

Returns the amount of time in milliseconds that a socket read between a sending GatewaySender and its receiving GatewayReceiver will block. The default is 10000 seconds.

Returns:

the amount of time in milliseconds that a socket read between a sending GatewaySender and its receiving GatewayReceiver will block

getDiskStoreName

String getDiskStoreName()

Gets the disk store name for overflow or persistence.

Returns:

disk store name

getMaximumQueueMemory

int getMaximumQueueMemory()

Returns the maximum amount of memory (in MB) for a GatewaySender's queue.

Returns:

maximum amount of memory (in MB) for a GatewaySender's queue

getBatchSize

int getBatchSize()

Returns the batch size for this GatewaySender.

Returns:

the batch size for this GatewaySender.

getBatchTimeInterval

int getBatchTimeInterval()

Returns the batch time interval for this GatewaySender.

Returns:

the batch time interval for this GatewaySender

isBatchConflationEnabled

boolean isBatchConflationEnabled()

Answers whether to enable batch conflation for a GatewaySender 's queue.

Returns:

whether to enable batch conflation for batches sent from a GatewaySender to its corresponding GatewayReceiver.

isPersistenceEnabled

boolean isPersistenceEnabled()

Returns true if persistence is enabled for this GatewaySender, otherwise returns false.

Returns:

true if persistence is enabled for this GatewaySender

getAlertThreshold

int getAlertThreshold()

Returns the alert threshold for entries in a GatewaySender's queue.

Returns:

the alert threshold for entries in a GatewaySender's queue

getGatewayEventFilters

List<GatewayEventFilter> getGatewayEventFilters()

Returns the list of GatewayEventFilter added to this GatewaySender.

Returns:

the list of GatewayEventFilter added to this GatewaySender.

getGatewayTransportFilters

List<GatewayTransportFilter> getGatewayTransportFilters()

Returns the list of GatewayTransportFilter added to this GatewaySender.

Returns:

the list of GatewayTransportFilter added to this GatewaySender.

isDiskSynchronous

boolean isDiskSynchronous()

Returns isDiskSynchronous boolean property for this GatewaySender.

Returns:

isDiskSynchronous boolean property for this GatewaySender

isManualStart

boolean isManualStart()

Returns the manual start boolean property for this GatewaySender.

Returns:

the manual start boolean property for this GatewaySender

isParallel

boolean isParallel()

Returns isParallel boolean property for this GatewaySender.

Returns:

isParallel boolean property for this GatewaySender

getDispatcherThreads

int getDispatcherThreads()

Returns the number of dispatcher threads working for this GatewaySender

Returns:

the number of dispatcher threads working for this GatewaySender

getOrderPolicy

Gateway.OrderPolicy getOrderPolicy()

Returns the order policy followed while dispatching the events to remote ds. Order policy is set only when dispatcher threads are > 1

Returns:

the order policy followed while dispatching the events to remote ds.