Class XSiteCacheRequest<T>

java.lang.Object

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

All Implemented Interfaces:

TracedCommand, 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
ByteString	getCacheName()
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.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.infinispan.commands.TracedCommand

getOperationName, getSpanAttributes, setSpanAttributes

Field Details

cacheName

protected ByteString cacheName

Constructor Details

XSiteCacheRequest

protected XSiteCacheRequest(ByteString cacheName)

Method Details

getCacheName

@ProtoField(1)
public ByteString getCacheName()

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)