com.hazelcast.client.spi.impl

Class ClientTransactionManagerServiceImpl

java.lang.Object

com.hazelcast.client.spi.impl.ClientTransactionManagerServiceImpl

All Implemented Interfaces:

ClientTransactionManagerService

public class ClientTransactionManagerServiceImpl
extends Object
implements ClientTransactionManagerService

Constructor Summary

Constructors

Constructor and Description
ClientTransactionManagerServiceImpl(HazelcastClientInstanceImpl client, LoadBalancer loadBalancer)

Method Summary

Modifier and Type	Method and Description
ClientConnection	connect()
<T> T	executeTransaction(TransactionalTask<T> task)
<T> T	executeTransaction(TransactionOptions options, TransactionalTask<T> task)
HazelcastClientInstanceImpl	getClient()
String	getGroupName()
TransactionContext	newTransactionContext()
TransactionContext	newTransactionContext(TransactionOptions options)
TransactionContext	newXATransactionContext(Xid xid, int timeoutInSeconds)
void	shutdown()

Methods inherited from class java.lang.Object

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

Constructor Detail

ClientTransactionManagerServiceImpl

public ClientTransactionManagerServiceImpl(HazelcastClientInstanceImpl client,
                                           LoadBalancer loadBalancer)

Method Detail

getClient

public HazelcastClientInstanceImpl getClient()

newTransactionContext

public TransactionContext newTransactionContext()

Specified by:

newTransactionContext in interface ClientTransactionManagerService

newTransactionContext

public TransactionContext newTransactionContext(TransactionOptions options)

Specified by:

newTransactionContext in interface ClientTransactionManagerService

executeTransaction

public <T> T executeTransaction(TransactionalTask<T> task)
                         throws TransactionException

Specified by:

executeTransaction in interface ClientTransactionManagerService

Throws:

TransactionException

executeTransaction

public <T> T executeTransaction(TransactionOptions options,
                                TransactionalTask<T> task)
                         throws TransactionException

Specified by:

executeTransaction in interface ClientTransactionManagerService

Throws:

TransactionException

newXATransactionContext

public TransactionContext newXATransactionContext(Xid xid,
                                                  int timeoutInSeconds)

Specified by:

newXATransactionContext in interface ClientTransactionManagerService

Parameters:

xid - branch qualifier

timeoutInSeconds - transaction timeout in seconds

Returns:

a TransactionContext for the supplied branch qualifier

shutdown

public void shutdown()

Specified by:

shutdown in interface ClientTransactionManagerService

getGroupName

public String getGroupName()

Specified by:

getGroupName in interface ClientTransactionManagerService

connect

public ClientConnection connect()
                         throws Exception

Throws:

Exception