public class TransactionManagerServiceImpl extends Object implements TransactionManagerService, ManagedService, MembershipAwareService, ClientAwareService
Modifier and Type | Field and Description |
---|---|
static int |
RECOVER_TIMEOUT |
static String |
SERVICE_NAME |
Constructor and Description |
---|
TransactionManagerServiceImpl(NodeEngineImpl nodeEngine) |
public static final String SERVICE_NAME
public static final int RECOVER_TIMEOUT
public TransactionManagerServiceImpl(NodeEngineImpl nodeEngine)
public <T> T executeTransaction(TransactionOptions options, TransactionalTask<T> task) throws TransactionException
executeTransaction
in interface TransactionManagerService
TransactionException
public TransactionContext newTransactionContext(TransactionOptions options)
newTransactionContext
in interface TransactionManagerService
public TransactionContext newClientTransactionContext(TransactionOptions options, String clientUuid)
newClientTransactionContext
in interface TransactionManagerService
public void init(NodeEngine nodeEngine, Properties properties)
ManagedService
init
in interface ManagedService
nodeEngine
- the NodeEngine this ManagedService is initialized with.properties
- the Propertiespublic void reset()
ManagedService
reset
in interface ManagedService
public void shutdown(boolean terminate)
ManagedService
shutdown
in interface ManagedService
public void memberAdded(MembershipServiceEvent event)
MembershipAwareService
memberAdded
in interface MembershipAwareService
public void addClientRecoveredTransaction(RecoveredTransaction rt)
public void recoverClientTransaction(SerializableXID sXid, boolean commit)
public void memberRemoved(MembershipServiceEvent event)
MembershipAwareService
memberRemoved
in interface MembershipAwareService
public void memberAttributeChanged(MemberAttributeServiceEvent event)
MembershipAwareService
memberAttributeChanged
in interface MembershipAwareService
public void addManagedTransaction(Xid xid, Transaction transaction)
public Transaction getManagedTransaction(Xid xid)
public void removeManagedTransaction(Xid xid)
public void clientDisconnected(String clientUuid)
ClientAwareService
clientDisconnected
in interface ClientAwareService
public void addTxBackupLogForClientRecovery(Transaction transaction)
public Xid[] recover()
public Set<RecoveredTransaction> recoverLocal()
Copyright © 2014 Hazelcast, Inc.. All rights reserved.