Uses of Class
com.loomcache.common.protocol.Message

Packages that use Message

Package	Description
com.loomcache.common.protocol
com.loomcache.server
com.loomcache.server.cluster
com.loomcache.server.consensus
com.loomcache.server.handler
com.loomcache.server.network
com.loomcache.server.observability
com.loomcache.server.replication
com.loomcache.server.security
com.loomcache.server.tracing
com.loomcache.server.transaction
com.loomcache.server.transaction.twopc
com.loomcache.server.wan

Uses of Message in com.loomcache.common.protocol

Methods in com.loomcache.common.protocol that return Message

Modifier and Type	Method	Description
Message	Message.copy()	Create a deep copy of this message.
Message	VersionedMessageAdapter.createFeatureUnavailableError(Feature feature, int correlationId)	Create an error message for an unsupported operation.
static @Nullable Message	MessageCodec.decode(InputStream in)	Decode a Message from an InputStream.
static @Nullable Message	MessageCodec.decode(InputStream in, WireCompression negotiatedCompression)	Decode a Message from an InputStream using the negotiated compression mode.
static @Nullable Message	MessageCodec.decode(ByteBuffer buf)	Decode from a ByteBuffer (for NIO channel reads).
static @Nullable Message	MessageCodec.decode(ByteBuffer buf, WireCompression negotiatedCompression)	Decode from a ByteBuffer using the negotiated compression mode.
@Nullable Message	VersionedMessageAdapter.decode(ByteBuffer buffer)	Decode a message from a ByteBuffer, implementing forward compatibility.
static Message	Message.request(MessageType type)	Create a request message.
static Message	Message.response(MessageType type, int correlationId)	Create a response message.
static Message	Message.response(MessageType type, int correlationId, byte status)	Create a response message with status.
Message	Message.withFlags(byte flags)	Set message flags.
Message	Message.withFreshCorrelationId()	Create a copy of this message with a fresh correlation ID.
Message	Message.withKey(byte @Nullable [] key)
Message	Message.withMapName(@Nullable String mapName)	Set the target data structure name (map, queue, or topic).
Message	Message.withSenderId(@Nullable String senderId)	Set the sender node ID.
Message	Message.withStatus(byte status)	Set the response status code.
Message	Message.withTtl(long ttlMillis)	Set the TTL for put operations.
Message	Message.withValue(byte @Nullable [] value)	Set the message value.

Methods in com.loomcache.common.protocol with parameters of type Message

Modifier and Type	Method	Description
static ByteBuffer	MessageCodec.encode(Message msg)	Encode a Message into a ByteBuffer (for NIO channel writes).
static ByteBuffer	MessageCodec.encode(Message msg, WireCompression compression)	Encode a Message into a ByteBuffer using the negotiated compression mode.
static void	MessageCodec.encode(Message msg, OutputStream out)	Encode a Message to an OutputStream (for traditional I/O).
static void	MessageCodec.encode(Message msg, OutputStream out, WireCompression compression)	Encode a Message to an OutputStream using the negotiated compression mode.
ByteBuffer	VersionedMessageAdapter.encode(Message message)	Encode a message, ensuring the message type is supported in the negotiated version.

Uses of Message in com.loomcache.server

Methods in com.loomcache.server that return Message

Modifier and Type	Method	Description
@Nullable Message	CacheNode.handleMessage(Message message, ConnectionContext sender)

Methods in com.loomcache.server with parameters of type Message

Modifier and Type	Method	Description
@Nullable Message	CacheNode.handleMessage(Message message, ConnectionContext sender)

Uses of Message in com.loomcache.server.cluster

Methods in com.loomcache.server.cluster with parameters of type Message

Modifier and Type	Method	Description
static boolean	PartitionMigrationManager.isMigrationRecoveryRequest(Message message)

Uses of Message in com.loomcache.server.consensus

Methods in com.loomcache.server.consensus that return Message

Modifier and Type	Method	Description
Message	RaftNode.handleAppendEntries(Message msg)	Handle incoming AppendEntries RPC (follower side).
Message	RaftNode.handleHeartbeat(Message msg)	Handle a Raft heartbeat (simplified AppendEntries with no entries).
Message	RaftNode.handleInstallSnapshot(Message msg)	Handle incoming InstallSnapshot RPC (follower side).
Message	RaftNode.handlePreVoteRequest(Message msg)	Handle an incoming PreVote request.
Message	RaftNode.handleTimeoutNow(Message msg)	Handle an incoming TIMEOUT_NOW RPC from the leader.
Message	RaftNode.handleVoteRequest(Message msg)	Handle an incoming RequestVote RPC.

Methods in com.loomcache.server.consensus with parameters of type Message

Modifier and Type	Method	Description
Message	RaftNode.handleAppendEntries(Message msg)	Handle incoming AppendEntries RPC (follower side).
void	RaftNode.handleAppendResponse(Message msg)	Handle AppendEntries response (leader side).
Message	RaftNode.handleHeartbeat(Message msg)	Handle a Raft heartbeat (simplified AppendEntries with no entries).
Message	RaftNode.handleInstallSnapshot(Message msg)	Handle incoming InstallSnapshot RPC (follower side).
void	RaftNode.handleInstallSnapshotResponse(Message msg)	Handle InstallSnapshot response (leader side).
Message	RaftNode.handlePreVoteRequest(Message msg)	Handle an incoming PreVote request.
void	RaftNode.handlePreVoteResponse(Message msg)	Handle an incoming PreVote response.
Message	RaftNode.handleTimeoutNow(Message msg)	Handle an incoming TIMEOUT_NOW RPC from the leader.
Message	RaftNode.handleVoteRequest(Message msg)	Handle an incoming RequestVote RPC.
void	RaftNode.handleVoteResponse(Message msg)	Handle an incoming VoteResponse.

Uses of Message in com.loomcache.server.handler

Methods in com.loomcache.server.handler that return Message

Modifier and Type	Method	Description
Message	IdempotencyManager.deduplicate(IdempotencyManager.IdempotencyKey key, Supplier<Message> supplier)	Deduplicates a request.
Message	IdempotencyManager.deduplicate(IdempotencyManager.IdempotencyKey key, Supplier<Message> supplier, Predicate<Exception> retainPendingOnException)
Message	IdempotencyManager.deduplicate(IdempotencyManager.IdempotencyKey key, Supplier<Message> supplier, Predicate<Exception> retainPendingOnException, boolean cpOperation)
Message	BatchExecutionHandler.handle(Message msg)	Handle a BATCH_EXECUTE message.
@Nullable Message	ConsistencySubsystemHandler.handle(Message msg)	Handle a Consistency operation message.
Message	CqcSubscriptionHandler.handle(String peerId, Message msg)	Dispatch a CQC_SUBSCRIBE or CQC_UNSUBSCRIBE message from the given peer.
@Nullable Message	DataOperationHandler.handle(Message msg)	Handles a single data-structure operation message.
@Nullable Message	ExecutorServiceHandler.handle(Message msg)	Handle an executor service operation message.
@Nullable Message	QueryHandler.handle(Message msg)	Handle a SQL query operation message.
@Nullable Message	QueryHandler.handle(Message msg, QueryHandler.SqlCatalogAuthorization sqlCatalogAuthorization)
@Nullable Message	ReadCoalescingFilter.handle(Message message)	Handle a message, applying coalescing for read operations.
Message	RequestCoalescer.GroupStats.originalRequest()	Returns the value of the originalRequest record component.
@Nullable Message	IdempotencyManager.peekCompleted(IdempotencyManager.IdempotencyKey key)	Returns a copy of the live cached response for the key, or null if no completed response is currently available.
Message	IdempotencyManager.CachedResponse.response()	Returns the value of the response record component.

Methods in com.loomcache.server.handler that return types with arguments of type Message

Modifier and Type	Method	Description
CompletableFuture<@Nullable Message>	RequestCoalescer.coalesce(RequestCoalescer.CoalescingKey key, Supplier<@Nullable Message> supplier)	Coalesce a read request or execute it if no group exists.

Methods in com.loomcache.server.handler with parameters of type Message

Modifier and Type	Method	Description
Message	BatchExecutionHandler.handle(Message msg)	Handle a BATCH_EXECUTE message.
@Nullable Message	ConsistencySubsystemHandler.handle(Message msg)	Handle a Consistency operation message.
Message	CqcSubscriptionHandler.handle(String peerId, Message msg)	Dispatch a CQC_SUBSCRIBE or CQC_UNSUBSCRIBE message from the given peer.
@Nullable Message	DataOperationHandler.handle(Message msg)	Handles a single data-structure operation message.
@Nullable Message	ExecutorServiceHandler.handle(Message msg)	Handle an executor service operation message.
@Nullable Message	QueryHandler.handle(Message msg)	Handle a SQL query operation message.
@Nullable Message	QueryHandler.handle(Message msg, QueryHandler.SqlCatalogAuthorization sqlCatalogAuthorization)
@Nullable Message	ReadCoalescingFilter.handle(Message message)	Handle a message, applying coalescing for read operations.
void	IdempotencyManager.recordCompleted(IdempotencyManager.IdempotencyKey key, Message response)	Record a completed idempotent response without executing the supplier again.
void	IdempotencyManager.recordCompleted(IdempotencyManager.IdempotencyKey key, Message response, boolean cpOperation)
Optional<String>	QueryHandler.validateMutationAuthorization(Message msg, QueryHandler.SqlCatalogAuthorization sqlCatalogAuthorization)

Method parameters in com.loomcache.server.handler with type arguments of type Message

Modifier and Type	Method	Description
CompletableFuture<@Nullable Message>	RequestCoalescer.coalesce(RequestCoalescer.CoalescingKey key, Supplier<@Nullable Message> supplier)	Coalesce a read request or execute it if no group exists.
Message	IdempotencyManager.deduplicate(IdempotencyManager.IdempotencyKey key, Supplier<Message> supplier)	Deduplicates a request.
Message	IdempotencyManager.deduplicate(IdempotencyManager.IdempotencyKey key, Supplier<Message> supplier, Predicate<Exception> retainPendingOnException)
Message	IdempotencyManager.deduplicate(IdempotencyManager.IdempotencyKey key, Supplier<Message> supplier, Predicate<Exception> retainPendingOnException, boolean cpOperation)

Constructors in com.loomcache.server.handler with parameters of type Message

Modifier	Constructor	Description
	CachedResponse(IdempotencyManager.IdempotencyKey key, Message response, long completedAt, long expiresAt, boolean cpOperation)	Creates an instance of a CachedResponse record class.
	GroupStats(Message originalRequest, int coalescedCount, long executionTimeNs)	Creates an instance of a GroupStats record class.

Uses of Message in com.loomcache.server.network

Methods in com.loomcache.server.network that return Message

Modifier and Type	Method	Description
Message	ProtocolHelloHandler.handle(Message request, ConnectionContext sender)	Handle an incoming PROTOCOL_HELLO request.
@Nullable Message	MessageHandler.handleMessage(Message message, ConnectionContext sender)	Handle an incoming message and optionally return a response.
Message	CommandContext.message()	Get the message to execute.

Methods in com.loomcache.server.network with parameters of type Message

Modifier and Type	Method	Description
Message	ProtocolHelloHandler.handle(Message request, ConnectionContext sender)	Handle an incoming PROTOCOL_HELLO request.
@Nullable Message	MessageHandler.handleMessage(Message message, ConnectionContext sender)	Handle an incoming message and optionally return a response.
void	ConnectionContext.send(Message msg)	Send a message to this peer.
boolean	TcpServer.sendMessage(String peerId, Message msg)	Send a message to a specific connected peer.

Constructors in com.loomcache.server.network with parameters of type Message

Modifier	Constructor	Description
	CommandContext(Message message, ConnectionContext connection)	Create a new command context for pipelined execution.

Uses of Message in com.loomcache.server.observability

Methods in com.loomcache.server.observability with parameters of type Message

Modifier and Type	Method	Description
@NonNull SlowOperationDetector.OperationScope	SlowOperationDetector.track(Message message, ConnectionContext connection)
@NonNull SlowOperationDetector.OperationScope	SlowOperationDetector.track(Message message, String peerId)

Uses of Message in com.loomcache.server.replication

Methods in com.loomcache.server.replication that return Message

Modifier and Type	Method	Description
Message	ReplicationManager.buildAckResponse(int correlationId, boolean success)	Build a REPL_ACK response message.

Methods in com.loomcache.server.replication with parameters of type Message

Modifier and Type	Method	Description
void	ReplicationManager.handleAck(Message msg)	Handle an incoming REPL_ACK message (primary side).
@Nullable ReplicationManager.ReplicationData	ReplicationManager.parseReplicationData(Message msg)	Handle an incoming REPL_SYNC message (backup side).

Uses of Message in com.loomcache.server.security

Methods in com.loomcache.server.security that return Message

Modifier and Type	Method	Description
Message	AuthenticationHandler.handleAuth(Message authMsg, ConnectionContext ctx)	Handle an AUTH message from a gateway-authenticated client.

Methods in com.loomcache.server.security with parameters of type Message

Modifier and Type	Method	Description
static SecurityOperationResult	SecurityOperationResult.completed(@Nullable Message response)
Message	AuthenticationHandler.handleAuth(Message authMsg, ConnectionContext ctx)	Handle an AUTH message from a gateway-authenticated client.

Uses of Message in com.loomcache.server.tracing

Methods in com.loomcache.server.tracing that return Message

Modifier and Type	Method	Description
Message	TracingInterceptor.MessageHandler.handle(Message message, ConnectionContext connectionContext)
Message	TracingInterceptor.intercept(Message message, ConnectionContext connectionContext, TracingInterceptor.MessageHandler handler)	Intercept an incoming message and trace it.

Methods in com.loomcache.server.tracing with parameters of type Message

Modifier and Type	Method	Description
static Map<String,String>	TraceContextPropagator.extractFromMessageBody(Message message)	Extract trace context from a message body (if stored there).
static Map<String,String>	TraceContextPropagator.extractTraceContext(Message message)	Extract trace context from an incoming message.
Message	TracingInterceptor.MessageHandler.handle(Message message, ConnectionContext connectionContext)
static boolean	TraceContextPropagator.hasTraceContext(Message message)	Check if a message contains trace context.
static void	TraceContextPropagator.injectTraceContext(Message message)	Inject trace context into a message for transmission to another node.
Message	TracingInterceptor.intercept(Message message, ConnectionContext connectionContext, TracingInterceptor.MessageHandler handler)	Intercept an incoming message and trace it.

Uses of Message in com.loomcache.server.transaction

Methods in com.loomcache.server.transaction that return Message

Modifier and Type	Method	Description
Message	TransactionHandler.handle(Message msg)	Dispatch an incoming TX_* message.

Methods in com.loomcache.server.transaction with parameters of type Message

Modifier and Type	Method	Description
Message	TransactionHandler.handle(Message msg)	Dispatch an incoming TX_* message.

Constructor parameters in com.loomcache.server.transaction with type arguments of type Message

Modifier	Constructor	Description
	TransactionHandler(TransactionManager transactionManager, int instanceNumber, @Nullable BiFunction<Message, MessageType, @Nullable Message> leaderRedirectSupplier)
	TransactionHandler(TransactionManager transactionManager, int instanceNumber, @Nullable BiFunction<Message, MessageType, @Nullable Message> leaderRedirectSupplier)

Uses of Message in com.loomcache.server.transaction.twopc

Methods in com.loomcache.server.transaction.twopc with parameters of type Message

Modifier and Type	Method	Description
boolean	PeerMessageDispatch.dispatch(@NonNull String targetNodeId, @NonNull Message message)	Send a message to a specific peer node.

Uses of Message in com.loomcache.server.wan

Methods in com.loomcache.server.wan that return Message

Modifier and Type	Method	Description
@Nullable Message	WanReplicationHandler.handle(@NonNull Message msg)	Handle a WAN replication protocol message.

Methods in com.loomcache.server.wan with parameters of type Message

Modifier and Type	Method	Description
@Nullable Message	WanReplicationHandler.handle(@NonNull Message msg)	Handle a WAN replication protocol message.