org.gridgain.grid.dr.hub.sender

Class GridDrSenderHubConfiguration

java.lang.Object

org.gridgain.grid.dr.hub.sender.GridDrSenderHubConfiguration

public class GridDrSenderHubConfiguration
extends Object

Data center replication sender hub configuration.

Field Summary

Fields

Modifier and Type	Field and Description
static long	DFLT_HEALTH_CHECK_FREQ Default health check frequency.
static int	DFLT_MAX_ERRORS Default maximum processing errors.
static int	DFLT_MAX_FAILED_CONNECT_ATTEMPTS Default maximum failed connect attempts.
static int	DFLT_MAX_QUEUE_SIZE Default maximum amount of enqueued requests per remote receiver hub.
static long	DFLT_READ_TIMEOUT Default read timeout.
static long	DFLT_RECONNECT_ON_FAILURE_TIMEOUT Reconnect on error timeout.
static long	DFLT_SYS_REQ_TIMEOUT Default ping timeout.

Constructor Summary

Constructors

Constructor and Description
GridDrSenderHubConfiguration() Default constructor.
GridDrSenderHubConfiguration(GridDrSenderHubConfiguration cfg) Copying constructor.

Method Summary

Methods

Modifier and Type	Method and Description
String[]	getCacheNames() Gets cache names this sender hub works with.
GridDrSenderHubConnectionConfiguration[]	getConnectionConfiguration() Get remote data center connection configurations.
long	getHealthCheckFrequency() Gets health check frequency.
int	getMaxErrors() Gets maximum amount of sequential errors in receiver hub responses.
int	getMaxFailedConnectAttempts() Gets maximum failed connect attempts.
int	getMaxQueueSize() Gets maximum wait queue size.
long	getReadTimeout() Gets read timeout.
long	getReconnectOnFailureTimeout() Gets reconnect-on-failure timeout.
GridDrSenderHubStore	getStore() Gets store.
long	getSystemRequestTimeout() Gets system request timeout.
void	setCacheNames(String... cacheNames) Set cache names this sender hub works with.
void	setConnectionConfiguration(GridDrSenderHubConnectionConfiguration... connCfg) Set remote data center connection configurations.
void	setHealthCheckFrequency(long healthCheckFreq) Sets health check frequency.
void	setMaxErrors(int maxErrors) Sets maximum amount of sequential errors in receiver hub responses.
void	setMaxFailedConnectAttempts(int maxFailedConnectAttempts) Set maximum failed connect attempts.
void	setMaxQueueSize(int maxQueueSize) Sets maximum wait queue size.
void	setReadTimeout(long readTimeout) Sets read timeout.
void	setReconnectOnFailureTimeout(long reconnectOnFailureTimeout) Sets reconnect-on-failure timeout.
void	setStore(GridDrSenderHubStore store) Sets store.
void	setSystemRequestTimeout(long sysReqTimeout) Sets system request timeout.
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

DFLT_MAX_FAILED_CONNECT_ATTEMPTS

public static final int DFLT_MAX_FAILED_CONNECT_ATTEMPTS

Default maximum failed connect attempts.

See Also:

Constant Field Values

DFLT_MAX_ERRORS

public static final int DFLT_MAX_ERRORS

Default maximum processing errors.

See Also:

Constant Field Values

DFLT_HEALTH_CHECK_FREQ

public static final long DFLT_HEALTH_CHECK_FREQ

Default health check frequency.

See Also:

Constant Field Values

DFLT_SYS_REQ_TIMEOUT

public static final long DFLT_SYS_REQ_TIMEOUT

Default ping timeout.

See Also:

Constant Field Values

DFLT_READ_TIMEOUT

public static final long DFLT_READ_TIMEOUT

Default read timeout.

See Also:

Constant Field Values

DFLT_MAX_QUEUE_SIZE

public static final int DFLT_MAX_QUEUE_SIZE

Default maximum amount of enqueued requests per remote receiver hub.

See Also:

Constant Field Values

DFLT_RECONNECT_ON_FAILURE_TIMEOUT

public static final long DFLT_RECONNECT_ON_FAILURE_TIMEOUT

Reconnect on error timeout.

See Also:

Constant Field Values

Constructor Detail

GridDrSenderHubConfiguration

public GridDrSenderHubConfiguration()

Default constructor.

GridDrSenderHubConfiguration

public GridDrSenderHubConfiguration(GridDrSenderHubConfiguration cfg)

Copying constructor.

Parameters:

cfg - Another sender hub configuration.

Method Detail

getConnectionConfiguration

public GridDrSenderHubConnectionConfiguration[] getConnectionConfiguration()

Get remote data center connection configurations. Defines data centers this sender hubs will work with.

Returns:

Remote data center connection configurations.

setConnectionConfiguration

public void setConnectionConfiguration(GridDrSenderHubConnectionConfiguration... connCfg)

Set remote data center connection configurations. See getConnectionConfiguration() for more information.

Parameters:

connCfg - Remote data center connection configurations.

getMaxFailedConnectAttempts

public int getMaxFailedConnectAttempts()

Gets maximum failed connect attempts. Once amount of failed sequential attmepts to connect to particular remote receiver hubs exceeds this limit, receiver hub will be considered offline. Further attempts to re-establish connection to this receiver hub will be performed according to getReconnectOnFailureTimeout() property.

Defaults to DFLT_MAX_FAILED_CONNECT_ATTEMPTS.

Returns:

Maximum failed connect attempts.

setMaxFailedConnectAttempts

public void setMaxFailedConnectAttempts(int maxFailedConnectAttempts)

Set maximum failed connect attempts. See getMaxFailedConnectAttempts() for more information.

Parameters:

maxFailedConnectAttempts - Maximum failed connect attempts.

getMaxErrors

public int getMaxErrors()

Gets maximum amount of sequential errors in receiver hub responses. When this threshold is reached, connection to this faulty receiver hub will be closed and reciver hub will be considered offline. Further attempts to re-establish connection to this receiver hub will be performed according to getReconnectOnFailureTimeout() property.

Defaults to DFLT_MAX_ERRORS.

Returns:

Maximum amount of sequential errors in receiver hub responses

setMaxErrors

public void setMaxErrors(int maxErrors)

Sets maximum amount of sequential errors in receiver hub responses. See getMaxErrors() for more information.

Parameters:

maxErrors - Maximum amount of sequential errors in receiver hub responses

getHealthCheckFrequency

public long getHealthCheckFrequency()

Gets health check frequency. Defines how often in milliseconds an attempt to restore connection to disconnected receiver hubs is performed and how often connected receiver hubs will be checked for necessity to send a ping request using getReadTimeout() property.

Defaults to DFLT_HEALTH_CHECK_FREQ.

Returns:

Health check frequency.

setHealthCheckFrequency

public void setHealthCheckFrequency(long healthCheckFreq)

Sets health check frequency. See getHealthCheckFrequency() for more information.

Parameters:

healthCheckFreq - Health check frequency.

getSystemRequestTimeout

public long getSystemRequestTimeout()

Gets system request timeout. Sender hub processor performs two types of system requests: handshake and ping. Handshake request contains information required by receiver hub and is only sent when network connection is established. Ping request just checks that receiver hub is reachable and responds when there was no reads from it for more than getReadTimeout().

In case any of these two requests was sent to receiver hub and there is no response for too long, it indicates a problem with either network connectivity or receiver hub itself. Thus, when the given timeout is exceeded, connection to receiver hub is closed.

Defaults to DFLT_SYS_REQ_TIMEOUT.

Returns:

System request timeout.

setSystemRequestTimeout

public void setSystemRequestTimeout(long sysReqTimeout)

Sets system request timeout. See getSystemRequestTimeout() for more information.

Parameters:

sysReqTimeout - System request timeout.

getReadTimeout

public long getReadTimeout()

Gets read timeout. When difference between current time and the time when last read operation on particular remote receiver hub occurred is greater than this timeout (in milliseconds), ping request will be sent to this receiver hub.

Defaults to DFLT_READ_TIMEOUT.

Returns:

Read timeout.

setReadTimeout

public void setReadTimeout(long readTimeout)

Sets read timeout. See getReadTimeout() for more information.

Parameters:

readTimeout - Read timeout.

getMaxQueueSize

public int getMaxQueueSize()

Gets maximum wait queue size. Defines maximum amount of entries which are read from store but have not been acknowledged yet.

Defaults to DFLT_MAX_QUEUE_SIZE.

Returns:

Maximum wait queue size.

setMaxQueueSize

public void setMaxQueueSize(int maxQueueSize)

Sets maximum wait queue size. See getMaxQueueSize() for more information.

Parameters:

maxQueueSize - Maximum wait queue size.

getReconnectOnFailureTimeout

public long getReconnectOnFailureTimeout()

Gets reconnect-on-failure timeout. This values defines timeout in milliseconds after which connection to remote receiver hub can be re-established in case it was previously disconnected due to a failure.

Defaults to DFLT_RECONNECT_ON_FAILURE_TIMEOUT.

Returns:

Reconnect-on-failure timeout.

setReconnectOnFailureTimeout

public void setReconnectOnFailureTimeout(long reconnectOnFailureTimeout)

Sets reconnect-on-failure timeout. See getReconnectOnFailureTimeout() for more information.

Parameters:

reconnectOnFailureTimeout - Reconnect-on-failure timeout.

getCacheNames

public String[] getCacheNames()

Gets cache names this sender hub works with. All sender hubs working with concrete cache must have this property equal. E.g., in case one sender hub works with caches A and B, then another sender hub cannot work with caches B and C. Instead, both sender hubs must work with either {A, B}, {B, C} or even {A, B, C} caches. However, it is possible for the first sender hub work with caches {A, B} and for the second sender hub to work with caches {C, D}.

Returns:

Cache names this sender hub works with.

setCacheNames

public void setCacheNames(@Nullable
                 String... cacheNames)

Set cache names this sender hub works with. See getCacheNames() for more information.

Parameters:

cacheNames - Cache names this sender hub works with.

getStore

public GridDrSenderHubStore getStore()

Gets store. All incoming sender cache batches will be saved in this store before being sent to receiver hubs. Once acknowledge for particular batch is received from all destination receiver hubs, this batch will be removed from store.

If set to null then GridDrSenderHubInMemoryStore will be used as a default.

Returns:

Store.

setStore

public void setStore(GridDrSenderHubStore store)

Sets store. See getStore() for more information.

Parameters:

store - Store.

toString

public String toString()

Overrides:

toString in class Object