Interface CacheRpcCommand
- All Superinterfaces:
ReplicableCommand, TracedCommand, VersionAware
- All Known Subinterfaces:
DataCommand, DataWriteCommand, FlagAffectedCommand, TransactionBoundaryCommand, VisitableCommand, WriteCommand
- All Known Implementing Classes:
AbstractDataCommand, AbstractDataWriteCommand, AbstractFlagAffectedCommand, AbstractLocalCommand, AbstractTopologyAffectedCommand, AbstractTransactionBoundaryCommand, AbstractWriteKeyCommand, AbstractWriteManyCommand, BackupMultiKeyAckCommand, BackupNoopCommand, BackupWriteCommand, BaseClusteredReadCommand, BaseRpcCommand, CheckTransactionRpcCommand, ClearCommand, ClusteredGetAllCommand, ClusteredGetCommand, CommitCommand, CompleteTransactionCommand, ComputeCommand, ComputeIfAbsentCommand, ConflictResolutionStartCommand, EntrySetCommand, EvictCommand, ExceptionAckCommand, GetAllCommand, GetCacheEntryCommand, GetInDoubtTransactionsCommand, GetInDoubtTxInfoCommand, GetKeyValueCommand, InvalidateCommand, InvalidateL1Command, IracCleanupKeysCommand, IracMetadataRequestCommand, IracPrimaryPendingKeyCheckCommand, IracPutKeyValueCommand, IracRequestStateCommand, IracStateResponseCommand, IracTombstoneCleanupCommand, IracTombstonePrimaryCheckCommand, IracTombstoneRemoteSiteCheckCommand, IracTombstoneStateResponseCommand, IracUpdateVersionCommand, KeySetCommand, LockControlCommand, MultiClusterEventCommand, MultiEntriesFunctionalBackupWriteCommand, MultiKeyFunctionalBackupWriteCommand, PrepareCommand, PutKeyValueCommand, PutMapBackupWriteCommand, PutMapCommand, ReadOnlyKeyCommand, ReadOnlyManyCommand, ReadWriteKeyCommand, ReadWriteKeyValueCommand, ReadWriteManyCommand, ReadWriteManyEntriesCommand, RemoveCommand, RemoveExpiredCommand, ReplaceCommand, RollbackCommand, SingleKeyBackupWriteCommand, SingleKeyFunctionalBackupWriteCommand, SizeCommand, StateResponseCommand, StateTransferCancelCommand, StateTransferGetListenersCommand, StateTransferGetTransactionsCommand, StateTransferStartCommand, TouchCommand, TxCompletionNotificationCommand, TxReadOnlyKeyCommand, TxReadOnlyManyCommand, VersionedCommitCommand, VersionedPrepareCommand, WriteOnlyKeyCommand, WriteOnlyKeyValueCommand, WriteOnlyManyCommand, WriteOnlyManyEntriesCommand, XSiteAmendOfflineStatusCommand, XSiteAutoTransferStatusCommand, XSiteSetStateTransferModeCommand, XSiteStatePushCommand, XSiteStateTransferCancelSendCommand, XSiteStateTransferClearStatusCommand, XSiteStateTransferFinishReceiveCommand, XSiteStateTransferFinishSendCommand, XSiteStateTransferRestartSendingCommand, XSiteStateTransferStartReceiveCommand, XSiteStateTransferStartSendCommand, XSiteStateTransferStatusRequestCommand
The
RpcManager only replicates commands wrapped in a CacheRpcCommand.- Since:
- 4.0
- Author:
- Manik Surtani, Mircea.Markus@jboss.com
-
Method Summary
Modifier and TypeMethodDescriptionGet the origin of the commandinvokeAsync(ComponentRegistry registry) Invoke the command asynchronously.voidSet the origin of the commandMethods inherited from interface ReplicableCommand
getCommandId, isReturnValueExpected, isSuccessful, logThrowable, readFrom, supportedSince, writeToMethods inherited from interface TracedCommand
getOperationName, getSpanAttributes, setSpanAttributes
-
Method Details
-
invokeAsync
Invoke the command asynchronously.- Throws:
Throwable- Since:
- 11.0
-
getCacheName
ByteString getCacheName()- Returns:
- the name of the cache that produced this command. This will also be the name of the cache this command is intended for.
-
setOrigin
Set the origin of the command- Specified by:
setOriginin interfaceReplicableCommand- Parameters:
origin- the sender'sAddress
-
getOrigin
Address getOrigin()Get the origin of the command
-