Package org.infinispan.server.hotrod.tx.operation

Class CommitTransactionOperation

java.lang.Object

org.infinispan.server.hotrod.tx.operation.CommitTransactionOperation

All Implemented Interfaces:

Runnable, CacheNameCollector

public class CommitTransactionOperation
extends Object

It commits a transaction in all involved caches.

Since:

9.4

Author:

Pedro Ruivo

Constructor Summary

Constructors

Constructor	Description
CommitTransactionOperation(HotRodHeader header, HotRodServer server, Subject subject, XidImpl xid, BiConsumer<HotRodHeader,Integer> reply)

Method Summary

Modifier and Type	Method	Description
void	addCache(ByteString cacheName, Status status)	Adds the cache name and the SetDecisionFunction return value.
void	expectedSize(int size)	Sets the expected number of caches involved in the transaction.
void	noTransactionFound()	Notifies that no transaction is found.
void	run()

Methods inherited from class java.lang.Object

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

Constructor Detail

CommitTransactionOperation

public CommitTransactionOperation(HotRodHeader header,
                                  HotRodServer server,
                                  Subject subject,
                                  XidImpl xid,
                                  BiConsumer<HotRodHeader,Integer> reply)

Method Detail

run

public void run()

addCache

public void addCache(ByteString cacheName,
                     Status status)

Description copied from interface: CacheNameCollector

Adds the cache name and the SetDecisionFunction return value.

expectedSize

public final void expectedSize(int size)

Description copied from interface: CacheNameCollector

Sets the expected number of caches involved in the transaction.

Specified by:

expectedSize in interface CacheNameCollector

noTransactionFound

public final void noTransactionFound()

Description copied from interface: CacheNameCollector

Notifies that no transaction is found.

Specified by:

noTransactionFound in interface CacheNameCollector