Package org.infinispan.commands.remote
Class RevokeBiasCommand
- java.lang.Object
-
- org.infinispan.commands.remote.BaseRpcCommand
-
- org.infinispan.commands.remote.RevokeBiasCommand
-
- All Implemented Interfaces:
CacheRpcCommand
,ReplicableCommand
public class RevokeBiasCommand extends BaseRpcCommand
Informs node that it is not allowed to serve reads from the local record anymore. After local bias is revoked aBackupAckCommand
is sent to the originator, and this confirms all keys.
-
-
Field Summary
Fields Modifier and Type Field Description static byte
COMMAND_ID
-
Fields inherited from class org.infinispan.commands.remote.BaseRpcCommand
cacheName
-
-
Constructor Summary
Constructors Constructor Description RevokeBiasCommand()
RevokeBiasCommand(ByteString cacheName)
RevokeBiasCommand(ByteString cacheName, Address ackTarget, long id, int topologyId, Collection<Object> keys)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description byte
getCommandId()
Used by marshallers to convert this command into an id for streaming.void
init(BiasManager biasManager, CommandsFactory commandsFactory, RpcManager rpcManager)
Object
invoke()
Invoke the command synchronously.boolean
isReturnValueExpected()
If true, a return value will be provided when performed remotely.void
readFrom(ObjectInput input)
Reads this instance from the stream written byReplicableCommand.writeTo(ObjectOutput)
.String
toString()
void
writeTo(ObjectOutput output)
Writes this instance to theObjectOutput
.-
Methods inherited from class org.infinispan.commands.remote.BaseRpcCommand
canBlock, getCacheName, getOrigin, setOrigin
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
-
Methods inherited from interface org.infinispan.commands.ReplicableCommand
invokeAsync, isSuccessful, perform
-
-
-
-
Field Detail
-
COMMAND_ID
public static final byte COMMAND_ID
- See Also:
- Constant Field Values
-
-
Constructor Detail
-
RevokeBiasCommand
public RevokeBiasCommand()
-
RevokeBiasCommand
public RevokeBiasCommand(ByteString cacheName)
-
RevokeBiasCommand
public RevokeBiasCommand(ByteString cacheName, Address ackTarget, long id, int topologyId, Collection<Object> keys)
-
-
Method Detail
-
init
public void init(BiasManager biasManager, CommandsFactory commandsFactory, RpcManager rpcManager)
-
invoke
public Object invoke() throws Throwable
Description copied from interface:ReplicableCommand
Invoke the command synchronously.This method is optional. Unless your command never blocks, please implement
ReplicableCommand.invokeAsync()
instead.- Throws:
Throwable
-
getCommandId
public byte getCommandId()
Description copied from interface:ReplicableCommand
Used by marshallers to convert this command into an id for streaming.- Returns:
- the method id of this command. This is compatible with pre-2.2.0 MethodCall ids.
-
isReturnValueExpected
public boolean isReturnValueExpected()
Description copied from interface:ReplicableCommand
If true, a return value will be provided when performed remotely. Otherwise, a remoteResponseGenerator
may choose to simply return null to save on marshalling costs.- Returns:
- true or false
-
writeTo
public void writeTo(ObjectOutput output) throws IOException
Description copied from interface:ReplicableCommand
Writes this instance to theObjectOutput
.- Parameters:
output
- the stream.- Throws:
IOException
- if an error occurred during the I/O.
-
readFrom
public void readFrom(ObjectInput input) throws IOException, ClassNotFoundException
Description copied from interface:ReplicableCommand
Reads this instance from the stream written byReplicableCommand.writeTo(ObjectOutput)
.- Parameters:
input
- the stream to read.- Throws:
IOException
- if an error occurred during the I/O.ClassNotFoundException
- if it tries to load an undefined class.
-
toString
public String toString()
- Overrides:
toString
in classBaseRpcCommand
-
-