com.hp.util.dcord.hazelcast

Class HazelcastConfiguration

java.lang.Object

com.hp.util.dcord.hazelcast.HazelcastConfiguration

public class HazelcastConfiguration
extends Object

Hazelcast configuration facade.

Author:

Fabiel Zuniga

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	HazelcastConfiguration.LoggingType Logging type.

Method Summary

Methods

Modifier and Type	Method and Description
void	disableUsePingWhenHeartbeatFails() Disable ICMP ping to verify the nodes in the cluster are reachable, when heartbeat times out due to high CPU usage or garbage collection.
void	enableUsePingWhenHeartbeatFails() Enable ICMP ping to verify the nodes in the cluster are reachable, when heartbeat times out due to high CPU usage or garbage collection.
static HazelcastConfiguration	forTcpIpDiscovery(PortNumber port, Collection<Host> cluster) Creates a connection configuration where TCP/IP is used to discover peers.
static HazelcastConfiguration	forTcpIpDiscovery(PortNumber port, Host... cluster) Creates a connection configuration where TCP/IP is used to discover peers.
Set<Host>	getCluster()
PortNumber	getPort()
void	setAsyncReplicationFactor(int asyncReplicationFactor) Sets the default asynchronous replication factor: number of backup copies among nodes.
void	setGracefulShutdownMaxWait(int seconds) Sets the seconds to wait for a graceful shutdown to occur.
void	setInstanceName(String name) Sets a friendly name for the hazelcast instance.
void	setJoinMaxWait(int seconds) Sets the maximum seconds to wait for the node to join the cluster.
void	setLoggingType(HazelcastConfiguration.LoggingType loggingType) Sets the logging type.
void	setMaxWaitForAllToConnect(int seconds) Sets the maximum seconds to wait for all nodes in the cluster to connect.
void	setMaxWaitToConfirmNoPartitionMaster(int seconds) Sets the maximum seconds to wait to confirm there is no partition master.
void	setMergeFirstRunDelay(int seconds) Sets the seconds to wait before running the first merge.
void	setMergeNextRunDelay(int seconds) Sets the seconds to wait before running all merges after the first one.
void	setNoHeartbeatMaxWait(int seconds) Sets the maximum seconds to wait without getting a heartbeat.
void	setPartitionBackupSyncInterval(int seconds) Sets the interval for partition backup synchronization.
void	setPartitionMasterConfirmationInterval(int seconds) Sets the interval to confirm who is the partition master.
void	setPartitionMigrationTimeout(int seconds) Sets the maximum seconds to wait for the partition migration to timeout.
void	setPort(PortNumber port) Sets the port.
void	setPublishPartitionMemberListInterval(int seconds) Sets the interval to publish the partition member list.
void	setReplicationFactor(int replicationFactor) Sets the default replication factor: number of backup copies among nodes.
String	toString()

Methods inherited from class java.lang.Object

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

Method Detail

forTcpIpDiscovery

public static HazelcastConfiguration forTcpIpDiscovery(PortNumber port,
                                       Host... cluster)

Creates a connection configuration where TCP/IP is used to discover peers.

Parameters:

port - local port

cluster - hosts that form the cluster. The entire cluster may be defined or just the other peers.

Returns:

a connection configuration

forTcpIpDiscovery

public static HazelcastConfiguration forTcpIpDiscovery(PortNumber port,
                                       Collection<Host> cluster)

Creates a connection configuration where TCP/IP is used to discover peers.

Parameters:

port - local port

cluster - hosts that form the cluster. The entire cluster may be defined or just the other peers.

Returns:

a connection configuration

setInstanceName

public void setInstanceName(String name)

Sets a friendly name for the hazelcast instance.

Parameters:

name - friendly name

getCluster

public Set<Host> getCluster()

getPort

public PortNumber getPort()

setPort

public void setPort(PortNumber port)

Sets the port.

Parameters:

port - the port, null to let the underlying implementation to choose one

enableUsePingWhenHeartbeatFails

public void enableUsePingWhenHeartbeatFails()

Enable ICMP ping to verify the nodes in the cluster are reachable, when heartbeat times out due to high CPU usage or garbage collection.

disableUsePingWhenHeartbeatFails

public void disableUsePingWhenHeartbeatFails()

Disable ICMP ping to verify the nodes in the cluster are reachable, when heartbeat times out due to high CPU usage or garbage collection.

setNoHeartbeatMaxWait

public void setNoHeartbeatMaxWait(int seconds)

Sets the maximum seconds to wait without getting a heartbeat.

Parameters:

seconds - time to wait

setGracefulShutdownMaxWait

public void setGracefulShutdownMaxWait(int seconds)

Sets the seconds to wait for a graceful shutdown to occur.

Parameters:

seconds - time to wait

setMergeFirstRunDelay

public void setMergeFirstRunDelay(int seconds)

Sets the seconds to wait before running the first merge.

Parameters:

seconds - time to wait

setMergeNextRunDelay

public void setMergeNextRunDelay(int seconds)

Sets the seconds to wait before running all merges after the first one.

Parameters:

seconds - time to wait

setMaxWaitForAllToConnect

public void setMaxWaitForAllToConnect(int seconds)

Sets the maximum seconds to wait for all nodes in the cluster to connect.

Parameters:

seconds - time to wait

setJoinMaxWait

public void setJoinMaxWait(int seconds)

Sets the maximum seconds to wait for the node to join the cluster.

Parameters:

seconds - time to wait

setPartitionMigrationTimeout

public void setPartitionMigrationTimeout(int seconds)

Sets the maximum seconds to wait for the partition migration to timeout.

Parameters:

seconds - time to wait

setPartitionBackupSyncInterval

public void setPartitionBackupSyncInterval(int seconds)

Sets the interval for partition backup synchronization.

Parameters:

seconds - the synchronization interval

setPartitionMasterConfirmationInterval

public void setPartitionMasterConfirmationInterval(int seconds)

Sets the interval to confirm who is the partition master.

Parameters:

seconds - the confirmation interval

setMaxWaitToConfirmNoPartitionMaster

public void setMaxWaitToConfirmNoPartitionMaster(int seconds)

Sets the maximum seconds to wait to confirm there is no partition master.

Parameters:

seconds - time to wait

setPublishPartitionMemberListInterval

public void setPublishPartitionMemberListInterval(int seconds)

Sets the interval to publish the partition member list.

Parameters:

seconds - the publish interval

setReplicationFactor

public void setReplicationFactor(int replicationFactor)

Sets the default replication factor: number of backup copies among nodes. If replication factor equals 1 then all data will be copied to another JVM for fail-safety (0 means no backup).

Default value:

• 1 for multicast discovery.
• quorum -1 for TCP discovery. QuorumCalculator is used to calculate a quorum from the cluster provided at forTcpIpDiscovery(PortNumber, Host...) or forTcpIpDiscovery(PortNumber, Collection).

Parameters:

replicationFactor - the replication factor

setAsyncReplicationFactor

public void setAsyncReplicationFactor(int asyncReplicationFactor)

Sets the default asynchronous replication factor: number of backup copies among nodes. If replication factor equals 1 then all data will be copied to another JVM for fail-safety (0 means no backup).

Default value: 1

Parameters:

asyncReplicationFactor - the asynchronous replication factor

setLoggingType

public void setLoggingType(HazelcastConfiguration.LoggingType loggingType)

Sets the logging type.

Parameters:

loggingType - logging type

toString

public String toString()

Overrides:

toString in class Object