Package org.infinispan.xsite.commands.remote

Class XSiteStatePushRequest

java.lang.Object

org.infinispan.xsite.commands.remote.XSiteCacheRequest<Void>

org.infinispan.xsite.commands.remote.XSiteStatePushRequest

All Implemented Interfaces:

XSiteRequest<Void>

public class XSiteStatePushRequest
extends XSiteCacheRequest<Void>

Wraps the state to be sent to another site.

It used when the backup strategy is set to BackupConfiguration.BackupStrategy.SYNC.

Since:

15.0

Field Summary

Fields inherited from class org.infinispan.xsite.commands.remote.XSiteCacheRequest

cacheName

Constructor Summary

Constructors

Constructor	Description
XSiteStatePushRequest()
XSiteStatePushRequest(ByteString cacheName, XSiteState[] chunk, long timeoutMillis)

Method Summary

Modifier and Type	Method	Description
byte	getCommandId()	Used by marshallers to convert this command into an id for streaming.
protected CompletionStage<Void>	invokeInLocalCache(String origin, ComponentRegistry registry)
XSiteRequest<Void>	readFrom(ObjectInput input)	Reads this instance from the stream written by XSiteRequest.writeTo(ObjectOutput).
void	writeTo(ObjectOutput output)	Writes this instance to the ObjectOutput.

Methods inherited from class org.infinispan.xsite.commands.remote.XSiteCacheRequest

invokeInLocalSite

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

XSiteStatePushRequest

public XSiteStatePushRequest()

XSiteStatePushRequest

public XSiteStatePushRequest(ByteString cacheName,
 XSiteState[] chunk,
 long timeoutMillis)

Method Details

invokeInLocalCache

protected CompletionStage<Void> invokeInLocalCache(String origin,
 ComponentRegistry registry)

Specified by:

invokeInLocalCache in class XSiteCacheRequest<Void>

getCommandId

public byte getCommandId()

Description copied from interface: XSiteRequest

Used by marshallers to convert this command into an id for streaming.

Returns:

the method id of this command.

writeTo

public void writeTo(ObjectOutput output)
             throws IOException

Description copied from interface: XSiteRequest

Writes this instance to the ObjectOutput.

Specified by:

writeTo in interface XSiteRequest<Void>

Overrides:

writeTo in class XSiteCacheRequest<Void>

Parameters:

output - the stream.

Throws:

IOException - if an error occurred during the I/O.

readFrom

public XSiteRequest<Void> readFrom(ObjectInput input)
                            throws IOException,
ClassNotFoundException

Description copied from interface: XSiteRequest

Reads this instance from the stream written by XSiteRequest.writeTo(ObjectOutput).

Specified by:

readFrom in interface XSiteRequest<Void>

Overrides:

readFrom in class XSiteCacheRequest<Void>

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.