public class ReplicableManagerFunctionCommand extends Object implements ReplicableCommand
EmbeddedCacheManager as an argument| Modifier and Type | Field and Description |
|---|---|
static byte |
COMMAND_ID |
| Constructor and Description |
|---|
ReplicableManagerFunctionCommand() |
ReplicableManagerFunctionCommand(Function<? super EmbeddedCacheManager,?> function) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
canBlock()
If true, the command is processed asynchronously in a thread provided by an Infinispan thread pool.
|
byte |
getCommandId()
Used by marshallers to convert this command into an id for streaming.
|
CompletableFuture<Object> |
invokeAsync()
Invoke the command asynchronously.
|
boolean |
isReturnValueExpected()
If true, a return value will be provided when performed remotely.
|
void |
readFrom(ObjectInput input)
Reads this instance from the stream written by
ReplicableCommand.writeTo(ObjectOutput). |
void |
writeTo(ObjectOutput output)
Writes this instance to the
ObjectOutput. |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitinvoke, isSuccessful, setOriginpublic static final byte COMMAND_ID
public ReplicableManagerFunctionCommand()
public ReplicableManagerFunctionCommand(Function<? super EmbeddedCacheManager,?> function)
public CompletableFuture<Object> invokeAsync() throws Throwable
ReplicableCommandinvokeAsync in interface ReplicableCommandThrowablepublic byte getCommandId()
ReplicableCommandgetCommandId in interface ReplicableCommandpublic void readFrom(ObjectInput input) throws IOException, ClassNotFoundException
ReplicableCommandReplicableCommand.writeTo(ObjectOutput).readFrom in interface ReplicableCommandinput - the stream to read.IOException - if an error occurred during the I/O.ClassNotFoundException - if it tries to load an undefined class.public void writeTo(ObjectOutput output) throws IOException
ReplicableCommandObjectOutput.writeTo in interface ReplicableCommandoutput - the stream.IOException - if an error occurred during the I/O.public boolean isReturnValueExpected()
ReplicableCommandResponseGenerator may choose to simply return null to save on marshalling
costs.isReturnValueExpected in interface ReplicableCommandpublic boolean canBlock()
ReplicableCommandcanBlock in interface ReplicableCommandtrue if the command can block/wait, false otherwiseCopyright © 2022 JBoss by Red Hat. All rights reserved.