Package org.apache.ignite.client.handler.requests.tx

Class ClientTransactionCommitRequest

java.lang.Object

org.apache.ignite.client.handler.requests.tx.ClientTransactionCommitRequest

public class ClientTransactionCommitRequest
extends Object

Client transaction commit request.

Constructor Summary

Constructors

Constructor	Description
ClientTransactionCommitRequest()

Method Summary

Modifier and Type	Method	Description
static boolean	merge(org.apache.ignite.internal.table.InternalTable table, int partId, String consistentId, long token, org.apache.ignite.internal.tx.InternalTransaction tx, boolean commit)	Attempts to merge server and client enlistments.
static CompletableFuture<ResponseWriter>	process(org.apache.ignite.internal.client.proto.ClientMessageUnpacker in, ClientResourceRegistry resources, ClientHandlerMetricSource metrics, org.apache.ignite.internal.hlc.ClockService clockService, org.apache.ignite.internal.table.IgniteTablesInternal igniteTables, boolean enableDirectMapping, org.apache.ignite.internal.hlc.HybridTimestampTracker tsTracker)	Processes the request.

Methods inherited from class java.lang.Object

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

Constructor Details

ClientTransactionCommitRequest

public ClientTransactionCommitRequest()

Method Details

process

public static CompletableFuture<ResponseWriter> process(org.apache.ignite.internal.client.proto.ClientMessageUnpacker in,
 ClientResourceRegistry resources,
 ClientHandlerMetricSource metrics,
 org.apache.ignite.internal.hlc.ClockService clockService,
 org.apache.ignite.internal.table.IgniteTablesInternal igniteTables,
 boolean enableDirectMapping,
 org.apache.ignite.internal.hlc.HybridTimestampTracker tsTracker)
                                                 throws org.apache.ignite.internal.lang.IgniteInternalCheckedException

Processes the request.

Parameters:

in - Unpacker.

resources - Resources.

metrics - Metrics.

clockService - Clock service.

igniteTables - Tables.

enableDirectMapping - Enable direct mapping flag.

Returns:

Future.

Throws:

org.apache.ignite.internal.lang.IgniteInternalCheckedException

merge

public static boolean merge(org.apache.ignite.internal.table.InternalTable table,
 int partId,
 String consistentId,
 long token,
 org.apache.ignite.internal.tx.InternalTransaction tx,
 boolean commit)

Attempts to merge server and client enlistments.

Parameters:

table - The table.

partId - Partition id.

consistentId - Node consistent id.

token - Enlistment token.

tx - The transaction.

commit - Merge mode: commit (with validation) or rollback (no validations).

Returns:

True if merged.