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(java.lang.String cacheName)
EndInvalidationCommand(java.lang.String cacheName, java.lang.Object[] keys, java.lang.Object lockOwner)

Method Summary

Modifier and Type	Method and Description
boolean	canBlock()
boolean	equals(java.lang.Object o)
byte	getCommandId()
int	hashCode()
boolean	isReturnValueExpected()
java.lang.Object	perform(org.infinispan.context.InvocationContext ctx)
void	readFrom(java.io.ObjectInput input)
void	setPutFromLoadValidator(PutFromLoadValidator putFromLoadValidator)
java.lang.String	toString()
void	writeTo(java.io.ObjectOutput output)

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

Methods inherited from interface org.infinispan.commands.ReplicableCommand

getParameters, setParameters

Constructor Detail

EndInvalidationCommand

public EndInvalidationCommand(java.lang.String cacheName)

EndInvalidationCommand

public EndInvalidationCommand(java.lang.String cacheName,
                              java.lang.Object[] keys,
                              java.lang.Object lockOwner)

Parameters:

cacheName - name of the cache to evict

Method Detail

perform

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

Throws:

java.lang.Throwable

getCommandId

public byte getCommandId()

writeTo

public void writeTo(java.io.ObjectOutput output)
             throws java.io.IOException

Throws:

java.io.IOException

readFrom

public void readFrom(java.io.ObjectInput input)
              throws java.io.IOException,
                     java.lang.ClassNotFoundException

Throws:

java.io.IOException

java.lang.ClassNotFoundException

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(java.lang.Object o)

Overrides:

equals in class java.lang.Object

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

toString

public java.lang.String toString()

Overrides:

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