Package org.infinispan.xsite.commands.remote

Interface XSiteRequest<T>

All Known Implementing Classes:

IracClearKeysRequest, IracPutManyRequest, IracTombstoneCheckRequest, IracTouchKeyRequest, IracUpdateKeyRequest, XSiteCacheRequest, XSiteRemoteEventCommand, XSiteStatePushRequest, XSiteStateTransferControlRequest

public interface XSiteRequest<T>

It represents a cross-site request.

Since:

15.0

Method Summary

Modifier and Type	Method	Description
byte	getCommandId()	Used by marshallers to convert this command into an id for streaming.
CompletionStage<T>	invokeInLocalSite(String origin, GlobalComponentRegistry registry)	This method is invoked by the receiver node.
default XSiteRequest<T>	readFrom(ObjectInput input)	Reads this instance from the stream written by writeTo(ObjectOutput).
default void	writeTo(ObjectOutput output)	Writes this instance to the ObjectOutput.

Method Details

invokeInLocalSite

CompletionStage<T> invokeInLocalSite(String origin,
 GlobalComponentRegistry registry)

This method is invoked by the receiver node.

The GlobalComponentRegistry gives access to every component managed by this cache manager.

Parameters:

origin - The sender site.

registry - The GlobalComponentRegistry.

getCommandId

byte getCommandId()

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

Returns:

the method id of this command.

writeTo

default void writeTo(ObjectOutput output)
              throws IOException

Writes this instance to the ObjectOutput.

Parameters:

output - the stream.

Throws:

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

readFrom

default XSiteRequest<T> readFrom(ObjectInput input)
                          throws IOException,
ClassNotFoundException

Reads this instance from the stream written by 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.