com.neurosys.hazelcast.etl

Class ListenItemOnHazelCast<T>

java.lang.Object

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

Type Parameters:

T - as payload type

All Implemented Interfaces:

com.hazelcast.core.ItemListener<T>, EventListener

Direct Known Subclasses:

ListenMapEntryOnHazelCast

public class ListenItemOnHazelCast<T>
extends Object
implements com.hazelcast.core.ItemListener<T>

For items that are added to IList type structure

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
Consumer<T>	getConsumer() Consumer of the object that came from the event
String	getContainerName() Name of the Distributed List or Map
protected com.hazelcast.core.ICollection<T>	getHazelCastCollection()
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	init() Bind this Listener to its Hazelcast vmInstance
void	itemAdded(com.hazelcast.core.ItemEvent<T> item)
void	itemRemoved(com.hazelcast.core.ItemEvent<T> item)
void	reInit(com.hazelcast.core.HazelcastInstance vmInstance)
void	setConsumer(Consumer<T> consumer) Consumer of the object that came from the event
void	setContainerName(String containerName) Name of the Distributed List or 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.

Methods inherited from class java.lang.Object

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

Constructor Detail

ListenItemOnHazelCast

public ListenItemOnHazelCast()

ListenItemOnHazelCast

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

ListenItemOnHazelCast

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

Method Detail

reInit

public void reInit(com.hazelcast.core.HazelcastInstance vmInstance)

init

@PostConstruct
public void init()

Bind this Listener to its Hazelcast vmInstance

itemAdded

public void itemAdded(com.hazelcast.core.ItemEvent<T> item)

Specified by:

itemAdded in interface com.hazelcast.core.ItemListener<T>

itemRemoved

public void itemRemoved(com.hazelcast.core.ItemEvent<T> item)

Specified by:

itemRemoved in interface com.hazelcast.core.ItemListener<T>

getHazelCastCollection

protected com.hazelcast.core.ICollection<T> getHazelCastCollection()

getContainerName

public String getContainerName()

Name of the Distributed List or Map

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

See Also:

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

getConsumer

public Consumer<T> getConsumer()

Consumer of the object that came from the event

setConsumer

public void setConsumer(Consumer<T> consumer)

Consumer of the object that came from the event

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.