public class WanConfigurationContext extends Object
WanPublisherConfig| 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_MAX_CONCURRENT_INVOCATIONS
Default value for maximum number of WAN event batches being transmitted
concurrently to the target cluster.
|
| 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.
|
String |
getGroupName()
Returns the group name of target cluster.
|
long |
getIdleMaxParkNs()
Returns the maximum amount of time in nanoseconds that the WAN
replication thread will idle if there are no events to be replicated.
|
long |
getIdleMinParkNs() |
int |
getMaxConcurrentInvocations()
Returns the maximum number of WAN event batches being sent to the target
cluster concurrently.
|
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. |
public static final int DEFAULT_BATCH_SIZE
WanBatchReplication.public static final int DEFAULT_MAX_CONCURRENT_INVOCATIONS
2 means
that there can be only one batch being sent to a single target endpoint at
any time. This way, the maximum number of WAN event batches being sent
concurrently depends on the target endpoint count and causality is
maintained for all events in a single partition.public boolean isSnapshotEnabled()
true if key-based coalescing is configured for this WAN
publisher.
When enabled, only the latest WanReplicationEvent
of a key is sent to target.public int getBatchSize()
WanReplicationProperties.BATCH_SIZEpublic long getBatchMaxDelayMillis()
getBatchSize() of events have not
arrived within this duration.public long getResponseTimeoutMillis()
public com.hazelcast.config.WanAcknowledgeType getAcknowledgeType()
WanReplicationProperties.ACK_TYPEpublic boolean isUseEndpointPrivateAddress()
true if the WAN connection manager should connect to the
endpoint on the private address returned by the discovery SPI.public String getGroupName()
WanPublisherConfig.getGroupName()public String getPassword()
WanReplicationProperties.GROUP_PASSWORDpublic int getMaxEndpoints()
WanReplicationProperties.MAX_ENDPOINTSpublic int getDiscoveryPeriodSeconds()
public String getEndpoints()
127.0.0.1:5701, 127.0.0.1:5702.WanReplicationProperties.ENDPOINTSpublic com.hazelcast.config.WanPublisherConfig getPublisherConfig()
public int getMaxConcurrentInvocations()
2 means only one batch
will be sent per target endpoint at any point in time.public long getIdleMinParkNs()
public long getIdleMaxParkNs()
Copyright © 2020 Hazelcast, Inc.. All Rights Reserved.