com.hazelcast.enterprise.wan.replication

Class WanConfigurationContext

java.lang.Object

com.hazelcast.enterprise.wan.replication.WanConfigurationContext

public class WanConfigurationContext
extends Object

WAN configuration context providing eager parsing of configuration. This context is valid for a single WAN publisher.

See Also:

WanPublisherConfig

Field Summary

Fields

Modifier and Type	Field and Description
static int	DEFAULT_BATCH_SIZE Default maximum size of a batch of events sent to the target cluster.
static int	DEFAULT_EXECUTOR_THREAD_COUNT Default number of threads that the WanBatchReplication executor will have.

Method Summary

Modifier and Type	Method and Description
com.hazelcast.config.WanAcknowledgeType	getAcknowledgeType() Returns the acknowledgement waiting type of WAN replication operation invocation.
long	getBatchMaxDelayMillis() Returns the maximum amount of time to be waited before sending a batch of events to target cluster, if getBatchSize() of events have not arrived within this duration.
int	getBatchSize() Returns the maximum batch size that can be sent to target cluster.
int	getDiscoveryPeriodSeconds() Returns the period in seconds in which WAN tries to discover new endpoints and reestablish connections to failed endpoints.
String	getEndpoints() Returns the comma separated list of target cluster members, e.g.
int	getExecutorThreadCount() Returns the number of threads that the WanBatchReplication executor must have.
String	getGroupName() Returns the group name of target cluster.
int	getMaxEndpoints() Returns the maximum number of endpoints that WAN will connect to when using a discovery mechanism to define endpoints.
String	getPassword() Returns the group password of target cluster.
com.hazelcast.config.WanPublisherConfig	getPublisherConfig() Returns the configuration for the WAN publisher for which this context is valid.
long	getResponseTimeoutMillis() Returns the duration in milliseconds to define waiting time before retrying to send the events to target cluster again in case of acknowledgement is not arrived.
boolean	isSnapshotEnabled() Retuns true if key-based coalescing is configured for this WAN publisher.
boolean	isUseEndpointPrivateAddress() Returns true if the WAN connection manager should connect to the endpoint on the private address returned by the discovery SPI.

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_EXECUTOR_THREAD_COUNT

public static final int DEFAULT_EXECUTOR_THREAD_COUNT

Default number of threads that the WanBatchReplication executor will have.

See Also:

WanReplicationProperties.EXECUTOR_THREAD_COUNT, Constant Field Values

DEFAULT_BATCH_SIZE

public static final int DEFAULT_BATCH_SIZE

Default maximum size of a batch of events sent to the target cluster. It comes into effect when used with the WanBatchReplication.

See Also:

WanReplicationProperties.BATCH_SIZE, Constant Field Values

Method Detail

isSnapshotEnabled

public boolean isSnapshotEnabled()

Retuns true if key-based coalescing is configured for this WAN publisher. When enabled, only the latest WanReplicationEvent of a key is sent to target.

See Also:

WanReplicationProperties.SNAPSHOT_ENABLED

getExecutorThreadCount

public int getExecutorThreadCount()

Returns the number of threads that the WanBatchReplication executor must have.

See Also:

WanReplicationProperties.EXECUTOR_THREAD_COUNT

getBatchSize

public int getBatchSize()

Returns the maximum batch size that can be sent to target cluster.

See Also:

WanReplicationProperties.BATCH_SIZE

getBatchMaxDelayMillis

public long getBatchMaxDelayMillis()

Returns the maximum amount of time to be waited before sending a batch of events to target cluster, if getBatchSize() of events have not arrived within this duration.

See Also:

WanReplicationProperties.BATCH_MAX_DELAY_MILLIS

getResponseTimeoutMillis

public long getResponseTimeoutMillis()

Returns the duration in milliseconds to define waiting time before retrying to send the events to target cluster again in case of acknowledgement is not arrived.

See Also:

WanReplicationProperties.RESPONSE_TIMEOUT_MILLIS

getAcknowledgeType

public com.hazelcast.config.WanAcknowledgeType getAcknowledgeType()

Returns the acknowledgement waiting type of WAN replication operation invocation.

See Also:

WanReplicationProperties.ACK_TYPE

isUseEndpointPrivateAddress

public boolean isUseEndpointPrivateAddress()

Returns true if the WAN connection manager should connect to the endpoint on the private address returned by the discovery SPI.

See Also:

WanReplicationProperties.DISCOVERY_USE_ENDPOINT_PRIVATE_ADDRESS

getGroupName

public String getGroupName()

Returns the group name of target cluster.

See Also:

WanPublisherConfig.getGroupName()

getPassword

public String getPassword()

Returns the group password of target cluster.

See Also:

WanReplicationProperties.GROUP_PASSWORD

getMaxEndpoints

public int getMaxEndpoints()

Returns the maximum number of endpoints that WAN will connect to when using a discovery mechanism to define endpoints.

See Also:

WanReplicationProperties.MAX_ENDPOINTS

getDiscoveryPeriodSeconds

public int getDiscoveryPeriodSeconds()

Returns the period in seconds in which WAN tries to discover new endpoints and reestablish connections to failed endpoints.

See Also:

WanReplicationProperties.DISCOVERY_PERIOD

getEndpoints

public String getEndpoints()

Returns the comma separated list of target cluster members, e.g. 127.0.0.1:5701, 127.0.0.1:5702.

See Also:

WanReplicationProperties.ENDPOINTS

getPublisherConfig

public com.hazelcast.config.WanPublisherConfig getPublisherConfig()

Returns the configuration for the WAN publisher for which this context is valid.

Returns:

WAN publisher configuration