com.neurosys.hazelcast.etl

Class ListenMapEntryOnHazelCast<T>

java.lang.Object

com.neurosys.hazelcast.etl.ListenItemOnHazelCast<com.hazelcast.core.EntryEvent<String,T>>

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

Type Parameters:

T - as payload type

All Implemented Interfaces:

com.hazelcast.core.ItemListener<com.hazelcast.core.EntryEvent<String,T>>, com.hazelcast.map.listener.EntryAddedListener<String,T>, com.hazelcast.map.listener.EntryUpdatedListener<String,T>, com.hazelcast.map.listener.MapListener, EventListener

public class ListenMapEntryOnHazelCast<T>
extends ListenItemOnHazelCast<com.hazelcast.core.EntryEvent<String,T>>
implements com.hazelcast.map.listener.MapListener, com.hazelcast.map.listener.EntryAddedListener<String,T>, com.hazelcast.map.listener.EntryUpdatedListener<String,T>

Listen for IMap events on HazelCast

Author:

Arjun Dhar

See Also:

SetupHazelCastInstance

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	entryAdded(com.hazelcast.core.EntryEvent<String,T> event)
void	entryUpdated(com.hazelcast.core.EntryEvent<String,T> event)
String	getEntryListenerId()
protected com.hazelcast.core.IMap<String,T>	getHazelCastMap()
void	init() Bind this Listener to its Hazelcast ListenItemOnHazelCast.vmInstance
void	itemAdded(com.hazelcast.core.ItemEvent<com.hazelcast.core.EntryEvent<String,T>> item)
void	itemRemoved(com.hazelcast.core.ItemEvent<com.hazelcast.core.EntryEvent<String,T>> item)
void	reInit(com.hazelcast.core.HazelcastInstance vmInstance)

Methods inherited from class com.neurosys.hazelcast.etl.ListenItemOnHazelCast

getConsumer, getContainerName, getHazelCastCollection, getVmInstance, setConsumer, setContainerName, setVmInstance

Methods inherited from class java.lang.Object

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

Constructor Detail

ListenMapEntryOnHazelCast

public ListenMapEntryOnHazelCast()

ListenMapEntryOnHazelCast

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

ListenMapEntryOnHazelCast

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

Method Detail

init

@PostConstruct
public void init()

Bind this Listener to its Hazelcast ListenItemOnHazelCast.vmInstance

Overrides:

init in class ListenItemOnHazelCast<com.hazelcast.core.EntryEvent<String,T>>

reInit

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

Overrides:

reInit in class ListenItemOnHazelCast<com.hazelcast.core.EntryEvent<String,T>>

getHazelCastMap

protected com.hazelcast.core.IMap<String,T> getHazelCastMap()

itemAdded

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

Specified by:

itemAdded in interface com.hazelcast.core.ItemListener<com.hazelcast.core.EntryEvent<String,T>>

Overrides:

itemAdded in class ListenItemOnHazelCast<com.hazelcast.core.EntryEvent<String,T>>

itemRemoved

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

Specified by:

itemRemoved in interface com.hazelcast.core.ItemListener<com.hazelcast.core.EntryEvent<String,T>>

Overrides:

itemRemoved in class ListenItemOnHazelCast<com.hazelcast.core.EntryEvent<String,T>>

entryUpdated

public void entryUpdated(com.hazelcast.core.EntryEvent<String,T> event)

Specified by:

entryUpdated in interface com.hazelcast.map.listener.EntryUpdatedListener<String,T>

entryAdded

public void entryAdded(com.hazelcast.core.EntryEvent<String,T> event)

Specified by:

entryAdded in interface com.hazelcast.map.listener.EntryAddedListener<String,T>

getEntryListenerId

public String getEntryListenerId()