Package org.infinispan.xsite.commands
Class XSiteStateTransferStartReceiveCommand
- java.lang.Object
-
- org.infinispan.commands.remote.BaseRpcCommand
-
- org.infinispan.xsite.XSiteReplicateCommand<Void>
-
- org.infinispan.xsite.commands.XSiteStateTransferStartReceiveCommand
-
- All Implemented Interfaces:
org.infinispan.commands.remote.CacheRpcCommand
,ReplicableCommand
public class XSiteStateTransferStartReceiveCommand extends org.infinispan.xsite.XSiteReplicateCommand<Void>
Start receiving XSite state.- Since:
- 11.0
- Author:
- Ryan Emerson
-
-
Field Summary
Fields Modifier and Type Field Description static byte
COMMAND_ID
-
Constructor Summary
Constructors Constructor Description XSiteStateTransferStartReceiveCommand()
XSiteStateTransferStartReceiveCommand(ByteString cacheName)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static XSiteStateTransferStartReceiveCommand
copyForCache(XSiteStateTransferStartReceiveCommand command, ByteString cacheName)
CompletionStage<?>
invokeAsync(ComponentRegistry registry)
CompletionStage<Void>
performInLocalSite(org.infinispan.xsite.BackupReceiver receiver, boolean preserveOrder)
void
readFrom(ObjectInput input)
Reads this instance from the stream written byReplicableCommand.writeTo(ObjectOutput)
.void
setSiteName(String siteName)
String
toString()
void
writeTo(ObjectOutput output)
Writes this instance to theObjectOutput
.-
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
canBlock, invoke, invokeAsync, isSuccessful, logThrowable
-
-
-
-
Field Detail
-
COMMAND_ID
public static final byte COMMAND_ID
- See Also:
- Constant Field Values
-
-
Constructor Detail
-
XSiteStateTransferStartReceiveCommand
public XSiteStateTransferStartReceiveCommand()
-
XSiteStateTransferStartReceiveCommand
public XSiteStateTransferStartReceiveCommand(ByteString cacheName)
-
-
Method Detail
-
invokeAsync
public CompletionStage<?> invokeAsync(ComponentRegistry registry)
-
performInLocalSite
public CompletionStage<Void> performInLocalSite(org.infinispan.xsite.BackupReceiver receiver, boolean preserveOrder)
-
setSiteName
public void setSiteName(String siteName)
-
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.
-
copyForCache
public static XSiteStateTransferStartReceiveCommand copyForCache(XSiteStateTransferStartReceiveCommand command, ByteString cacheName)
-
-