Class EndInvalidationCommand
- java.lang.Object
-
- org.infinispan.commands.remote.BaseRpcCommand
-
- org.infinispan.hibernate.cache.commons.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.- Author:
- Radim Vansa <rvansa@redhat.com>
-
-
Constructor Summary
Constructors Constructor Description EndInvalidationCommand(org.infinispan.util.ByteString cacheName)
EndInvalidationCommand(org.infinispan.util.ByteString cacheName, Object[] keys, Object lockOwner)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
canBlock()
boolean
equals(Object o)
byte
getCommandId()
int
hashCode()
boolean
isReturnValueExpected()
Object
perform(org.infinispan.context.InvocationContext ctx)
void
readFrom(ObjectInput input)
void
setPutFromLoadValidator(PutFromLoadValidator putFromLoadValidator)
String
toString()
void
writeTo(ObjectOutput output)
-
Methods inherited from class org.infinispan.commands.remote.BaseRpcCommand
getCacheName, getOrigin, setOrigin
-
-
-
-
Method Detail
-
perform
public Object perform(org.infinispan.context.InvocationContext ctx) throws Throwable
- Throws:
Throwable
-
getCommandId
public byte getCommandId()
-
writeTo
public void writeTo(ObjectOutput output) throws IOException
- Throws:
IOException
-
readFrom
public void readFrom(ObjectInput input) throws IOException, ClassNotFoundException
- Throws:
IOException
ClassNotFoundException
-
isReturnValueExpected
public boolean isReturnValueExpected()
-
canBlock
public boolean canBlock()
- Specified by:
canBlock
in interfaceorg.infinispan.commands.ReplicableCommand
- Overrides:
canBlock
in classorg.infinispan.commands.remote.BaseRpcCommand
-
setPutFromLoadValidator
public void setPutFromLoadValidator(PutFromLoadValidator putFromLoadValidator)
-
toString
public String toString()
- Overrides:
toString
in classorg.infinispan.commands.remote.BaseRpcCommand
-
-