com.neurosys.hazelcast.etl

Class SendOnHazelCast<T>

java.lang.Object

com.neurosys.hazelcast.etl.SendOnHazelCast<T>

Type Parameters:

T - as payload Object to send over HazelCast

All Implemented Interfaces:

UpdatableContext<Supplier<com.hazelcast.core.HazelcastInstance>>, Serializable, Consumer<T>, org.apache.commons.collections.Transformer

public class SendOnHazelCast<T>
extends Object
implements Consumer<T>, org.apache.commons.collections.Transformer, UpdatableContext<Supplier<com.hazelcast.core.HazelcastInstance>>

Send an Object over HaxelCast

Code sample:

		ListenItemOnHazelCast<TestObj> listener = new ListenItemOnHazelCast(hazelcastInstance, "tracking-data"); //Send listen on different instances (NON CLUSTERED)
		final Count count = new Count();
		listener.setConsumer(new Consumer<TestObj>() {
			public void accept(TestObj t) {
				log.info("[LISTENER] " + listener.getContainerName() + " > " + t);
				count.pass++;
				Assert.assertEquals("xy"+t.i, t.s); //Simply check pattern matches x<vlaue of i>
				count.pass++;			
			}
		});
		listener.init(); //bind listener to HZ
		
		SendOnHazelCast&lt;TestObj&gt; send = new SendOnHazelCast(hazelcastInstance, "tracking-data");
		send.accept(new TestObj("x1", 1)); //Pattern of data x<vlaue of i>
		send.accept(new TestObj("x2", 2));
		send.accept(new TestObj("x3", 3));
 

Author:

Arjun Dhar

See Also:

SetupHazelCastInstance, Serialized Form

Constructor Summary

Constructors

Constructor and Description
SendOnHazelCast()
SendOnHazelCast(com.hazelcast.core.HazelcastInstance vmInstance, String containerName)
SendOnHazelCast(Supplier<com.hazelcast.core.HazelcastInstance> vmInstance, String containerName)

Method Summary

Modifier and Type	Method and Description
void	accept(T t) Put the payload object on a IList or IMap depending on getKey
String	getContainerName() Name of the Distributed List or Map Note: Dont confuse containerName for groupName
Function<T,String>	getGetKey() For the input t, get the key name; if t has to be put on a Distributed Map.
Supplier<com.hazelcast.core.HazelcastInstance>	getVmInstance() Context Supplier of HazelcastInstance. This allows us to pass a instance via context in a more dynamic multi instance environment or one configured directly into this instance.
void	put(com.hazelcast.core.HazelcastInstance vmInstance, String key, T t)
void	put(String key, T t)
void	send(com.hazelcast.core.HazelcastInstance vmInstance, T t) Send payload to a particular HazelcastInstance
void	setContainerName(String containerName) Name of the Distributed List or Map Note: Dont confuse containerName for groupName
void	setGetKey(Function<T,String> getKey) For the input t, get the key name; if t has to be put on a Distributed Map.
void	setVmInstance(Supplier<com.hazelcast.core.HazelcastInstance> vmInstance) Context Supplier of HazelcastInstance. This allows us to pass a instance via context in a more dynamic multi instance environment or one configured directly into this instance.
Object	transform(Object input)
void	updateContext(Supplier<com.hazelcast.core.HazelcastInstance> context)

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.function.Consumer

andThen

Constructor Detail

SendOnHazelCast

public SendOnHazelCast()

SendOnHazelCast

public SendOnHazelCast(Supplier<com.hazelcast.core.HazelcastInstance> vmInstance,
                       String containerName)

SendOnHazelCast

public SendOnHazelCast(com.hazelcast.core.HazelcastInstance vmInstance,
                       String containerName)

Method Detail

transform

public Object transform(Object input)

Specified by:

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

accept

public void accept(T t)

Put the payload object on a IList or IMap depending on getKey

Specified by:

accept in interface Consumer<T>

send

public void send(com.hazelcast.core.HazelcastInstance vmInstance,
                 T t)

Send payload to a particular HazelcastInstance

Parameters:

vmInstance - as HazelcastInstance

t - as type for payload

put

public void put(String key,
                T t)

put

public void put(com.hazelcast.core.HazelcastInstance vmInstance,
                String key,
                T t)

getVmInstance

public Supplier<com.hazelcast.core.HazelcastInstance> getVmInstance()

Context Supplier of HazelcastInstance.
This allows us to pass a instance via context in a more dynamic multi instance environment or one configured directly into this instance.

setVmInstance

public void setVmInstance(Supplier<com.hazelcast.core.HazelcastInstance> vmInstance)

Context Supplier of HazelcastInstance.
This allows us to pass a instance via context in a more dynamic multi instance environment or one configured directly into this instance.

getContainerName

public String getContainerName()

Name of the Distributed List or Map
Note: Dont confuse containerName for groupName

See Also:

HazelcastInstance.getMap(String), if Map or List will be used.

setContainerName

public void setContainerName(String containerName)

Name of the Distributed List or Map
Note: Dont confuse containerName for groupName

See Also:

HazelcastInstance.getMap(String), if Map or List will be used.

getGetKey

public Function<T,String> getGetKey()

For the input t, get the key name; if t has to be put on a Distributed Map.

Parameters:

t - as

Returns:

null or key as String. null means List not Map (no key)

Default value:

null (List)

setGetKey

public void setGetKey(Function<T,String> getKey)

For the input t, get the key name; if t has to be put on a Distributed Map.

Parameters:

t - as

Default value:

null (List)

updateContext

public void updateContext(Supplier<com.hazelcast.core.HazelcastInstance> context)

Specified by:

updateContext in interface UpdatableContext<Supplier<com.hazelcast.core.HazelcastInstance>>