Class XSiteStatePushCommand
- java.lang.Object
-
- org.infinispan.commands.remote.BaseRpcCommand
-
- org.infinispan.xsite.XSiteReplicateCommand
-
- org.infinispan.xsite.statetransfer.XSiteStatePushCommand
-
- All Implemented Interfaces:
org.infinispan.commands.InitializableCommand
,org.infinispan.commands.remote.CacheRpcCommand
,org.infinispan.commands.ReplicableCommand
public class XSiteStatePushCommand extends XSiteReplicateCommand implements org.infinispan.commands.InitializableCommand
Wraps the state to be sent to another site- Since:
- 7.0
- Author:
- Pedro Ruivo
-
-
Field Summary
Fields Modifier and Type Field Description static byte
COMMAND_ID
-
Constructor Summary
Constructors Constructor Description XSiteStatePushCommand()
XSiteStatePushCommand(ByteString cacheName)
XSiteStatePushCommand(ByteString cacheName, XSiteState[] chunk, long timeoutMillis)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
canBlock()
If true, the command is processed asynchronously in a thread provided by an Infinispan thread pool.XSiteState[]
getChunk()
byte
getCommandId()
Used by marshallers to convert this command into an id for streaming.long
getTimeout()
void
init(ComponentRegistry componentRegistry, boolean isRemote)
java.util.concurrent.CompletableFuture<java.lang.Object>
invokeAsync()
Invoke the command asynchronously.boolean
isReturnValueExpected()
If true, a return value will be provided when performed remotely.java.util.concurrent.CompletionStage<java.lang.Void>
performInLocalSite(BackupReceiver receiver, boolean preserveOrder)
void
readFrom(java.io.ObjectInput input)
Reads this instance from the stream written byReplicableCommand.writeTo(ObjectOutput)
.java.lang.String
toString()
void
writeTo(java.io.ObjectOutput output)
Writes this instance to theObjectOutput
.-
Methods inherited from class org.infinispan.xsite.XSiteReplicateCommand
getOriginSite, setOriginSite
-
Methods inherited from class org.infinispan.commands.remote.BaseRpcCommand
getCacheName, getOrigin, setOrigin
-
-
-
-
Field Detail
-
COMMAND_ID
public static final byte COMMAND_ID
- See Also:
- Constant Field Values
-
-
Constructor Detail
-
XSiteStatePushCommand
public XSiteStatePushCommand(ByteString cacheName, XSiteState[] chunk, long timeoutMillis)
-
XSiteStatePushCommand
public XSiteStatePushCommand(ByteString cacheName)
-
XSiteStatePushCommand
public XSiteStatePushCommand()
-
-
Method Detail
-
performInLocalSite
public java.util.concurrent.CompletionStage<java.lang.Void> performInLocalSite(BackupReceiver receiver, boolean preserveOrder)
- Specified by:
performInLocalSite
in classXSiteReplicateCommand
-
init
public void init(ComponentRegistry componentRegistry, boolean isRemote)
- Specified by:
init
in interfaceorg.infinispan.commands.InitializableCommand
-
getChunk
public XSiteState[] getChunk()
-
getTimeout
public long getTimeout()
-
invokeAsync
public java.util.concurrent.CompletableFuture<java.lang.Object> invokeAsync() throws java.lang.Throwable
Description copied from interface:org.infinispan.commands.ReplicableCommand
Invoke the command asynchronously.This method replaces
ReplicableCommand.perform(InvocationContext)
for remote execution. The default implementation andReplicableCommand.perform(InvocationContext)
will be removed in future versions.- Specified by:
invokeAsync
in interfaceorg.infinispan.commands.ReplicableCommand
- Throws:
java.lang.Throwable
-
getCommandId
public byte getCommandId()
Description copied from interface:org.infinispan.commands.ReplicableCommand
Used by marshallers to convert this command into an id for streaming.- Specified by:
getCommandId
in interfaceorg.infinispan.commands.ReplicableCommand
- Returns:
- the method id of this command. This is compatible with pre-2.2.0 MethodCall ids.
-
writeTo
public void writeTo(java.io.ObjectOutput output) throws java.io.IOException
Description copied from interface:org.infinispan.commands.ReplicableCommand
Writes this instance to theObjectOutput
.- Specified by:
writeTo
in interfaceorg.infinispan.commands.ReplicableCommand
- Parameters:
output
- the stream.- Throws:
java.io.IOException
- if an error occurred during the I/O.
-
readFrom
public void readFrom(java.io.ObjectInput input) throws java.io.IOException, java.lang.ClassNotFoundException
Description copied from interface:org.infinispan.commands.ReplicableCommand
Reads this instance from the stream written byReplicableCommand.writeTo(ObjectOutput)
.- Specified by:
readFrom
in interfaceorg.infinispan.commands.ReplicableCommand
- Parameters:
input
- the stream to read.- Throws:
java.io.IOException
- if an error occurred during the I/O.java.lang.ClassNotFoundException
- if it tries to load an undefined class.
-
isReturnValueExpected
public boolean isReturnValueExpected()
Description copied from interface:org.infinispan.commands.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.- Specified by:
isReturnValueExpected
in interfaceorg.infinispan.commands.ReplicableCommand
- Returns:
- true or false
-
canBlock
public boolean canBlock()
Description copied from interface:org.infinispan.commands.ReplicableCommand
If true, the command is processed asynchronously in a thread provided by an Infinispan thread pool. Otherwise, the command is processed directly in the JGroups thread. This feature allows to avoid keep a JGroups thread busy that can originate discard of messages and retransmissions. So, the commands that can block (waiting for some state, acquiring locks, etc.) should return true.- Specified by:
canBlock
in interfaceorg.infinispan.commands.ReplicableCommand
- Overrides:
canBlock
in classorg.infinispan.commands.remote.BaseRpcCommand
- Returns:
true
if the command can block/wait,false
otherwise
-
toString
public java.lang.String toString()
- Overrides:
toString
in classorg.infinispan.commands.remote.BaseRpcCommand
-
-