org.gridgain.grid.dr

Interface DrSenderMBean

@MXBeanDescription(value="MBean that provides access to sender hub descriptor.")
public interface DrSenderMBean

This interface defines JMX view on data center replication sender hub.

Method Summary

Modifier and Type	Method and Description
String	getCacheNames() Gets cache names this sender hub works with.
long	getHealthCheckFrequency() Gets health check frequency in milliseconds.
int	getMaxErrors() Maximum amount of errors received from remote data center sender hub node.
int	getMaxFailedConnectAttempts() Gets maximum failed connection attempts.
int	getMaxQueueSize() Gets maximum wait queue size.
long	getReadTimeout() Gets read timeout in milliseconds.
long	getReconnectOnFailureTimeout() Timeout after which node can be reconnected in case it was previously disconnected due to a failure.
String	getSenderGroups() Gets group names this sender hub participate in.
long	getSystemRequestTimeout() Gets system request timeout.
String	metricsFormatted() Gets metrics (statistics) for this sender hub.
void	pause() Pause replication to all remote DCs.
void	pause(byte dcId) Pause replication for given DC.
boolean	paused(byte dcId) Returns DC pause flag.
String	remoteDataCentersFormatted() Gets formatted remote data centers configuration info.
void	resume() Resume replication for all remote DCs.
void	resume(byte dcId) Resume replication for given DC.

Method Detail

pause

@MXBeanDescription(value="Pause replication to remote DCs.")
void pause()

Pause replication to all remote DCs.

resume

@MXBeanDescription(value="Resume replication to remote DCs.")
void resume()

Resume replication for all remote DCs.

pause

@MXBeanDescription(value="Pause replication for given DC.")
void pause(byte dcId)

Pause replication for given DC.

Parameters:

dcId - Remote data center id.

paused

@MXBeanDescription(value="Returns DC pause flag.")
boolean paused(byte dcId)

Returns DC pause flag.

Parameters:

dcId - Remote data center id.

Returns:

true if given DC was paused.

resume

@MXBeanDescription(value="Resume replication for given DC.")
void resume(byte dcId)

Resume replication for given DC.

Parameters:

dcId - Remote data center id.

metricsFormatted

@MXBeanDescription(value="Formatted sender hub metrics.")
String metricsFormatted()

Gets metrics (statistics) for this sender hub.

Returns:

Sender hub metrics.

getMaxQueueSize

@MXBeanDescription(value="Maximum size of wait queue.")
int getMaxQueueSize()

Gets maximum wait queue size. When there are too many replication requests coming to sender hub and it cannot process them at the same speed, it is necessary to restrict maximum waiting requests size in order to avoid out-of-memory issues.

Returns:

Maximum wait queue size.

getHealthCheckFrequency

@MXBeanDescription(value="Health check frequency in milliseconds.")
long getHealthCheckFrequency()

Gets health check frequency in milliseconds. This frequency shows how often disconnected nodes will try reconnect and how often connected nodes will be checked for necessity to send a ping request.

Returns:

Ping frequency.

getSystemRequestTimeout

@MXBeanDescription(value="System request timeout.")
long getSystemRequestTimeout()

Gets system request timeout. Replication processor performs two types of system requests: handshake and ping. Handshake request contains information required by receiving side and is only sent when network connection is established. Ping request just checks that receiving side is reachable and responds when there was no reads from it for too long. In case any of these two requests was sent to receiving hub and there is no response for too long, it indicates a problem with either connectivity or receiving hub itself. Thus, when the given timeout is exceeded, remote sender hub node is disconnected.

Returns:

System request timeout in milliseconds.

getReadTimeout

@MXBeanDescription(value="Read timeout in milliseconds.")
long getReadTimeout()

Gets read timeout in milliseconds. In case difference between current time and the time when last read operation occurred is greater than this timeout, ping request will be sent to remote sender hub.

Returns:

Read timeout in milliseconds.

getMaxFailedConnectAttempts

@MXBeanDescription(value="Maximum failed connection attempts.")
int getMaxFailedConnectAttempts()

Gets maximum failed connection attempts. When this limit is reached, remote data center sender hub node gets disconnected.

Returns:

Maximum failed connect attempts.

getMaxErrors

@MXBeanDescription(value="Maximum amount of errors received from the remote data center.")
int getMaxErrors()

Maximum amount of errors received from remote data center sender hub node. When this limit is reached, remote data center sender hub node gets disconnected.

Returns:

Maximum errors.

getReconnectOnFailureTimeout

@MXBeanDescription(value="Node reconnection timeout after failure.")
long getReconnectOnFailureTimeout()

Timeout after which node can be reconnected in case it was previously disconnected due to a failure.

Returns:

Reconnect-on-failure timeout.

getCacheNames

@MXBeanDescription(value="Cache names.")
String getCacheNames()

Gets cache names this sender hub works with.

Returns:

Cache names this sender hub works with.

getSenderGroups

@MXBeanDescription(value="Sender groups.")
String getSenderGroups()

Gets group names this sender hub participate in.

Returns:

Sender groups this sender hub participate in.

remoteDataCentersFormatted

@MXBeanDescription(value="Formatted remote data centers configuration info.")
String remoteDataCentersFormatted()

Gets formatted remote data centers configuration info.

Returns:

Formatted remote data centers configuration info.