Package org.infinispan.xsite.commands.remote

Interface XSiteRequest<T>

All Superinterfaces:

TracedCommand

All Known Implementing Classes:

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

public interface XSiteRequest<T>
extends TracedCommand

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.

Methods inherited from interface org.infinispan.commands.TracedCommand

getOperationName, getSpanAttributes, setSpanAttributes

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.