com.hazelcast.cache.impl.journal

Class DeserializingEventJournalCacheEvent<K,V>

java.lang.Object

com.hazelcast.cache.impl.journal.InternalEventJournalCacheEvent

com.hazelcast.cache.impl.journal.DeserializingEventJournalCacheEvent<K,V>

All Implemented Interfaces:

EventJournalCacheEvent<K,V>, HazelcastInstanceAware, DataSerializable, IdentifiedDataSerializable

public class DeserializingEventJournalCacheEvent<K,V>
extends InternalEventJournalCacheEvent
implements EventJournalCacheEvent<K,V>, HazelcastInstanceAware

Field Summary

Fields inherited from class com.hazelcast.cache.impl.journal.InternalEventJournalCacheEvent

dataKey, dataNewValue, dataOldValue, eventType

Constructor Summary

Constructors

Constructor and Description
DeserializingEventJournalCacheEvent()
DeserializingEventJournalCacheEvent(SerializationService serializationService, InternalEventJournalCacheEvent je)

Method Summary

Modifier and Type	Method and Description
int	getId() Returns type identifier for this class.
K	getKey() Returns the key for the event entry.
V	getNewValue() Returns the new value for the event entry.
V	getOldValue() Returns the old value for the event entry.
CacheEventType	getType() Returns the event type.
void	setHazelcastInstance(HazelcastInstance hazelcastInstance) Gets the HazelcastInstance reference when submitting a Runnable/Callable using Hazelcast ExecutorService.
void	writeData(ObjectDataOutput out) Writes object fields to output stream

Methods inherited from class com.hazelcast.cache.impl.journal.InternalEventJournalCacheEvent

equals, getDataKey, getDataNewValue, getDataOldValue, getEventType, getFactoryId, hashCode, readData, toString

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

DeserializingEventJournalCacheEvent

public DeserializingEventJournalCacheEvent()

DeserializingEventJournalCacheEvent

public DeserializingEventJournalCacheEvent(SerializationService serializationService,
                                           InternalEventJournalCacheEvent je)

Method Detail

getId

public int getId()

Description copied from interface: IdentifiedDataSerializable

Returns type identifier for this class. It should be unique per DataSerializableFactory.

Specified by:

getId in interface IdentifiedDataSerializable

Overrides:

getId in class InternalEventJournalCacheEvent

Returns:

type ID

getKey

public K getKey()

Description copied from interface: EventJournalCacheEvent

Returns the key for the event entry.

Specified by:

getKey in interface EventJournalCacheEvent<K,V>

Returns:

the entry key

getNewValue

public V getNewValue()

Description copied from interface: EventJournalCacheEvent

Returns the new value for the event entry. In some cases this is null while in other cases it may be non-null. For instance, when the event is of type CacheEventType.CREATED, the new value is non-null but when it is of type CacheEventType.REMOVED, the value is null.

Specified by:

getNewValue in interface EventJournalCacheEvent<K,V>

Returns:

the entry new value

getOldValue

public V getOldValue()

Description copied from interface: EventJournalCacheEvent

Returns the old value for the event entry. In some cases this is null while in other cases it may be non-null. For instance, when the event is of type CacheEventType.CREATED, the old value is null but when it is of type CacheEventType.REMOVED, the value is non-null.

Specified by:

getOldValue in interface EventJournalCacheEvent<K,V>

Returns:

the entry old value

getType

public CacheEventType getType()

Description copied from interface: EventJournalCacheEvent

Returns the event type.

Specified by:

getType in interface EventJournalCacheEvent<K,V>

Returns:

the event type

writeData

public void writeData(ObjectDataOutput out)
               throws IOException

Description copied from interface: DataSerializable

Writes object fields to output stream

Specified by:

writeData in interface DataSerializable

Overrides:

writeData in class InternalEventJournalCacheEvent

Parameters:

out - output

Throws:

IOException - if an I/O error occurs. In particular, an IOException may be thrown if the output stream has been closed.

setHazelcastInstance

public void setHazelcastInstance(HazelcastInstance hazelcastInstance)

Description copied from interface: HazelcastInstanceAware

Gets the HazelcastInstance reference when submitting a Runnable/Callable using Hazelcast ExecutorService.

Specified by:

setHazelcastInstance in interface HazelcastInstanceAware

Parameters:

hazelcastInstance - the HazelcastInstance reference