Uses of Class
com.hazelcast.config.WanBatchPublisherConfig
-
Uses of WanBatchPublisherConfig in com.hazelcast.config
Modifier and TypeMethodDescriptionWanBatchPublisherConfig.setAcknowledgeType
(WanAcknowledgeType acknowledgeType) Sets the strategy for when the target cluster should acknowledge that a WAN event batch has been processed.WanBatchPublisherConfig.setAwsConfig
(AwsConfig awsConfig) Sets theAwsConfig
used by the discovery mechanism for this WAN publisher.WanBatchPublisherConfig.setAzureConfig
(AzureConfig azureConfig) Sets theAzureConfig
used by the discovery mechanism for this WAN publisher.WanBatchPublisherConfig.setBatchMaxDelayMillis
(int batchMaxDelayMillis) Sets the maximum amount of time in milliseconds to wait before sending a batch of events to target cluster, ifgetBatchSize()
of events have not arrived within this duration.WanBatchPublisherConfig.setBatchSize
(int batchSize) Sets the maximum batch size that can be sent to target cluster.WanBatchPublisherConfig.setClassName
(String className) WanBatchPublisherConfig.setClusterName
(String clusterName) Sets the cluster name used as an endpoint group password for authentication on the target endpoint.WanBatchPublisherConfig.setDiscoveryConfig
(DiscoveryConfig discoveryConfig) Sets theDiscoveryConfig
used by the discovery mechanism for this WAN publisher.WanBatchPublisherConfig.setDiscoveryPeriodSeconds
(int discoveryPeriodSeconds) Sets the period in seconds in which WAN tries to discover new target endpoints and reestablish connections to failed endpoints.WanBatchPublisherConfig.setEndpoint
(String endpoint) Sets the WAN endpoint configuration qualifier.WanBatchPublisherConfig.setEurekaConfig
(EurekaConfig eurekaConfig) Sets theEurekaConfig
used by the discovery mechanism for this WAN publisher.WanBatchPublisherConfig.setGcpConfig
(GcpConfig gcpConfig) Sets theGcpConfig
used by the discovery mechanism for this WAN publisher.WanBatchPublisherConfig.setIdleMaxParkNs
(long idleMaxParkNs) Sets the maximum duration in nanoseconds that the WAN replication thread will be parked if there are no events to replicate.WanBatchPublisherConfig.setIdleMinParkNs
(long idleMinParkNs) Sets the minimum duration in nanoseconds that the WAN replication thread will be parked if there are no events to replicate.WanBatchPublisherConfig.setImplementation
(WanPublisher implementation) No-op method as the implementation cannot be changed for this publisher.WanBatchPublisherConfig.setInitialPublisherState
(WanPublisherState initialPublisherState) Sets the initial publisher state.WanBatchPublisherConfig.setKubernetesConfig
(KubernetesConfig kubernetesConfig) Sets theKubernetesConfig
used by the discovery mechanism for this WAN publisher.WanBatchPublisherConfig.setMaxConcurrentInvocations
(int maxConcurrentInvocations) Sets the maximum number of WAN event batches being sent to the target cluster concurrently.WanBatchPublisherConfig.setMaxTargetEndpoints
(int maxTargetEndpoints) Sets the maximum number of endpoints that WAN will connect to when using a discovery mechanism to define endpoints.WanBatchPublisherConfig.setProperties
(Map<String, Comparable> properties) WanBatchPublisherConfig.setPublisherId
(String publisherId) WanBatchPublisherConfig.setQueueCapacity
(int queueCapacity) Sets the capacity of the primary and backup queue for WAN replication events.WanBatchPublisherConfig.setQueueFullBehavior
(WanQueueFullBehavior queueFullBehavior) Sets the configured behaviour of this WAN publisher when the WAN queue is full.WanBatchPublisherConfig.setResponseTimeoutMillis
(int responseTimeoutMillis) Sets the duration in milliseconds for the waiting time before retrying to send the events to target cluster again in case of acknowledgement is not arrived.WanBatchPublisherConfig.setSnapshotEnabled
(boolean snapshotEnabled) Sets if key-based coalescing is configured for this WAN publisher.WanBatchPublisherConfig.setSyncConfig
(WanSyncConfig syncConfig) Sets the config for the WAN sync mechanism.WanBatchPublisherConfig.setTargetEndpoints
(String targetEndpoints) Sets the comma separated list of target cluster members, e.g.WanBatchPublisherConfig.setUseEndpointPrivateAddress
(boolean useEndpointPrivateAddress) Sets whether the WAN connection manager should connect to the endpoint on the private address returned by the discovery SPI.Modifier and TypeMethodDescriptionWanReplicationConfig.getBatchPublisherConfigs()
Returns the list of WAN publisher configurations using the built-in batching WAN implementation for this WAN replication.Modifier and TypeMethodDescriptionWanReplicationConfig.addBatchReplicationPublisherConfig
(WanBatchPublisherConfig config) Adds a WAN publisher configuration using the built-in batching WAN implementation to this WAN replication.Modifier and TypeMethodDescriptionWanReplicationConfig.setBatchPublisherConfigs
(List<WanBatchPublisherConfig> batchPublisherConfigs) Sets the list of WAN publisher configurations using the built-in batching WAN implementation for this WAN replication.