Package org.infinispan.xsite.commands.remote

Class XSiteCacheRequest<T>

java.lang.Object

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

All Implemented Interfaces:

XSiteRequest<T>

Direct Known Subclasses:

IracTombstoneCheckRequest, IracUpdateKeyRequest, XSiteStatePushRequest, XSiteStateTransferControlRequest

public abstract class XSiteCacheRequest<T>
extends Object
implements XSiteRequest<T>

A XSiteRequest which is associated to a cache.

The subclass requests have access to the cache's ComponentRegistry via invokeInLocalCache(String, ComponentRegistry).

Since:

15.0

Field Summary

Fields

Modifier and Type	Field	Description
protected ByteString	cacheName

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	XSiteCacheRequest(ByteString cacheName)

Method Summary

Modifier and Type	Method	Description
protected abstract CompletionStage<T>	invokeInLocalCache(String origin, ComponentRegistry registry)
final CompletionStage<T>	invokeInLocalSite(String origin, GlobalComponentRegistry registry)	This method is invoked by the receiver node.
XSiteRequest<T>	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 java.lang.Object

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

Methods inherited from interface org.infinispan.xsite.commands.remote.XSiteRequest

getCommandId

Field Details

cacheName

protected ByteString cacheName

Constructor Details

XSiteCacheRequest

protected XSiteCacheRequest(ByteString cacheName)

Method Details

invokeInLocalSite

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

Description copied from interface: XSiteRequest

This method is invoked by the receiver node.

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

Specified by:

invokeInLocalSite in interface XSiteRequest<T>

Parameters:

origin - The sender site.

registry - The GlobalComponentRegistry.

invokeInLocalCache

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

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<T>

Parameters:

output - the stream.

Throws:

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

readFrom

public XSiteRequest<T> 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<T>

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.