com.neurosys.hazelcast.etl

Class SetupHazelCastInstance<V extends VMConnectInfo>

java.lang.Object

com.neurosys.hazelcast.etl.SetupHazelCastInstance<V>

All Implemented Interfaces:

Supplier<com.hazelcast.core.HazelcastInstance>, org.apache.commons.collections.Transformer

public class SetupHazelCastInstance<V extends VMConnectInfo>
extends Object
implements Supplier<com.hazelcast.core.HazelcastInstance>, org.apache.commons.collections.Transformer

Setup this VM on a single group name.
Note: The groupName derived from VMConnectInfo.getVmId() decides the cluster.

Code sample:

 		VMConnectInfo vm = new VMConnectInfo();
		SetupHazelCastInstance hz = (new SetupHazelCastInstance(vm)).init();
		HazelcastInstance hcInstance = hz.getInstance(); //Ref to native hazelcast Instance that can be used for adapters
 

Author:

Arjun Dhar

See Also:

SetupHazelCastInstances

Constructor Summary

Constructors

Constructor and Description
SetupHazelCastInstance()
SetupHazelCastInstance(String groupName)
SetupHazelCastInstance(String groupName, Integer thisInstancePort) Deprecated. Use SetupHazelCastInstance(VMConnectInfo) instead
SetupHazelCastInstance(VMConnectInfo vminfo)

Method Summary

Modifier and Type	Method and Description
SetupHazelCastInstance	addVM(VMConnectInfo vmInfo) Add a VM to an init()ialized HazelcastInstance
com.hazelcast.core.HazelcastInstance	get() Creates a new instance if none exists or existing is not running else return existing.
com.hazelcast.core.HazelcastInstance	getInstance()
static String	getInstanceName(String groupName, Integer thisPort) Generate a handle from VMConnectInfo so that if one wants to retrieve the actual Hazelcast.getHazelcastInstanceByName(String), then they both agree and a raw instance can be fetched from the native HazelCast API.
static String	getInstanceName(VMConnectInfo vmInfo) Generate a handle from VMConnectInfo so that if one wants to retrieve the actual Hazelcast.getHazelcastInstanceByName(String), then they both agree and a raw instance can be fetched from the native HazelCast API.
Integer	getThisInstancePort() What is the port# of this VM instance
VMConnectInfo	getVMInfo()
SetupHazelCastInstance	init() Create instance
boolean	isMultiCastConfigEnabled()
boolean	isPortIncrement()
void	setMultiCastConfigEnabled(boolean multiCastConfigEnabled)
void	setPortIncrement(boolean portIncrement)
void	setThisInstancePort(Integer thisInstancePort) What is the port# of this VM instance
void	shutDown()
Object	transform(Object input)

Methods inherited from class java.lang.Object

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

Constructor Detail

SetupHazelCastInstance

public SetupHazelCastInstance()

SetupHazelCastInstance

public SetupHazelCastInstance(String groupName)

SetupHazelCastInstance

@Deprecated
public SetupHazelCastInstance(String groupName,
                                          Integer thisInstancePort)

Deprecated. Use SetupHazelCastInstance(VMConnectInfo) instead

SetupHazelCastInstance

public SetupHazelCastInstance(VMConnectInfo vminfo)

Method Detail

init

public SetupHazelCastInstance init()

Create instance

Returns:

SetupHazelCastInstance

transform

public Object transform(Object input)

Specified by:

transform in interface org.apache.commons.collections.Transformer

getInstanceName

public static String getInstanceName(VMConnectInfo vmInfo)

Generate a handle from VMConnectInfo so that if one wants to retrieve the actual Hazelcast.getHazelcastInstanceByName(String), then they both agree and a raw instance can be fetched from the native HazelCast API.

Parameters:

vmInfo - as VMConnectInfo

Returns:

name as String

getInstanceName

public static String getInstanceName(String groupName,
                                     Integer thisPort)

Generate a handle from VMConnectInfo so that if one wants to retrieve the actual Hazelcast.getHazelcastInstanceByName(String), then they both agree and a raw instance can be fetched from the native HazelCast API.

Parameters:

groupName - as String

thisPort - as port same as thisInstancePort

Returns:

name as String

get

public com.hazelcast.core.HazelcastInstance get()

Creates a new instance if none exists or existing is not running else return existing.

Specified by:

get in interface Supplier<com.hazelcast.core.HazelcastInstance>

See Also:

to get a ready made instance. This one created it if {@link #instance} is null.

addVM

public SetupHazelCastInstance addVM(VMConnectInfo vmInfo)

Add a VM to an init()ialized HazelcastInstance

Parameters:

vmInfo -

Returns:

shutDown

public void shutDown()

getThisInstancePort

public Integer getThisInstancePort()

What is the port# of this VM instance

Default value:

5706

setThisInstancePort

public void setThisInstancePort(Integer thisInstancePort)

What is the port# of this VM instance

Default value:

5706

isMultiCastConfigEnabled

public boolean isMultiCastConfigEnabled()

See Also:

JoinConfig#getMulticastConfig().setEnabled

Default value:

false

setMultiCastConfigEnabled

public void setMultiCastConfigEnabled(boolean multiCastConfigEnabled)

See Also:

JoinConfig#getMulticastConfig().setEnabled

Default value:

false

isPortIncrement

public boolean isPortIncrement()

See Also:

NetworkConfig.setPortAutoIncrement(boolean)

setPortIncrement

public void setPortIncrement(boolean portIncrement)

See Also:

NetworkConfig.setPortAutoIncrement(boolean)

getInstance

public com.hazelcast.core.HazelcastInstance getInstance()

getVMInfo

public VMConnectInfo getVMInfo()