org.infinispan.client.hotrod.event.impl

Class ModifiedEventImpl<K>

java.lang.Object

org.infinispan.client.hotrod.event.impl.AbstractClientEvent

org.infinispan.client.hotrod.event.impl.ModifiedEventImpl<K>

All Implemented Interfaces:

ClientCacheEntryModifiedEvent<K>, ClientEvent

public class ModifiedEventImpl<K>
extends AbstractClientEvent
implements ClientCacheEntryModifiedEvent<K>

Nested Class Summary

Nested classes/interfaces inherited from interface org.infinispan.client.hotrod.event.ClientEvent

ClientEvent.Type

Constructor Summary

Constructors

Constructor and Description
ModifiedEventImpl(byte[] listenerId, K key, long version, boolean retried)

Method Summary

Modifier and Type	Method and Description
K	getKey() Modifiedcache entry's key.
ClientEvent.Type	getType()
long	getVersion() Provides access to the version of the modified cache entry.
boolean	isCommandRetried() This will be true if the write command that caused this had to be retried again due to a topology change.
String	toString()

Methods inherited from class org.infinispan.client.hotrod.event.impl.AbstractClientEvent

getListenerId

Methods inherited from class java.lang.Object

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

Constructor Detail

ModifiedEventImpl

public ModifiedEventImpl(byte[] listenerId,
                         K key,
                         long version,
                         boolean retried)

Method Detail

getKey

public K getKey()

Description copied from interface: ClientCacheEntryModifiedEvent

Modifiedcache entry's key.

Specified by:

getKey in interface ClientCacheEntryModifiedEvent<K>

Returns:

an instance of the key with which a cache entry has been modified in the remote server(s).

getVersion

public long getVersion()

Description copied from interface: ClientCacheEntryModifiedEvent

Provides access to the version of the modified cache entry. This version can be used to invoke conditional operations on the server, such as RemoteCache.replaceWithVersion(Object, Object, long) or RemoteCache.removeWithVersion(Object, long)

Specified by:

getVersion in interface ClientCacheEntryModifiedEvent<K>

Returns:

a long containing the version of the modified cache entry.

isCommandRetried

public boolean isCommandRetried()

Description copied from interface: ClientCacheEntryModifiedEvent

This will be true if the write command that caused this had to be retried again due to a topology change. This could be a sign that this event has been duplicated or another event was dropped and replaced (eg: ModifiedEvent replaced CreateEvent)

Specified by:

isCommandRetried in interface ClientCacheEntryModifiedEvent<K>

Returns:

Whether the command that caused this event was retried

getType

public ClientEvent.Type getType()

Specified by:

getType in interface ClientEvent

toString

public String toString()

Overrides:

toString in class Object