org.hibernate.cache.infinispan.util

Class EndInvalidationCommand

java.lang.Object

org.infinispan.commands.remote.BaseRpcCommand

org.hibernate.cache.infinispan.util.EndInvalidationCommand

All Implemented Interfaces:

org.infinispan.commands.remote.CacheRpcCommand, org.infinispan.commands.ReplicableCommand

public class EndInvalidationCommand
extends org.infinispan.commands.remote.BaseRpcCommand

Sent in commit phase (after DB commit) to remote nodes in order to stop invalidating putFromLoads.

Field Summary

Fields inherited from class org.infinispan.commands.remote.BaseRpcCommand

cacheName

Constructor Summary

Constructors

Constructor and Description
EndInvalidationCommand(String cacheName)
EndInvalidationCommand(String cacheName, Object[] keys, Object sessionTransactionId)

Method Summary

Modifier and Type	Method and Description
boolean	canBlock()
boolean	equals(Object o)
byte	getCommandId()
Object[]	getParameters()
int	hashCode()
boolean	isReturnValueExpected()
Object	perform(org.infinispan.context.InvocationContext ctx)
void	setParameters(int commandId, Object[] parameters)
void	setPutFromLoadValidator(PutFromLoadValidator putFromLoadValidator)
String	toString()

Methods inherited from class org.infinispan.commands.remote.BaseRpcCommand

getCacheName, getOrigin, setOrigin

Methods inherited from class java.lang.Object

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

Constructor Detail

EndInvalidationCommand

public EndInvalidationCommand(String cacheName)

EndInvalidationCommand

public EndInvalidationCommand(String cacheName,
                              Object[] keys,
                              Object sessionTransactionId)

Parameters:

cacheName - name of the cache to evict

Method Detail

perform

public Object perform(org.infinispan.context.InvocationContext ctx)
               throws Throwable

Throws:

Throwable

getCommandId

public byte getCommandId()

getParameters

public Object[] getParameters()

setParameters

public void setParameters(int commandId,
                          Object[] parameters)

isReturnValueExpected

public boolean isReturnValueExpected()

canBlock

public boolean canBlock()

Specified by:

canBlock in interface org.infinispan.commands.ReplicableCommand

Overrides:

canBlock in class org.infinispan.commands.remote.BaseRpcCommand

setPutFromLoadValidator

public void setPutFromLoadValidator(PutFromLoadValidator putFromLoadValidator)

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class org.infinispan.commands.remote.BaseRpcCommand