public class TransactionManagerServiceImpl extends Object implements TransactionManagerService, ManagedService, MembershipAwareService, ClientAwareService
Modifier and Type | Field and Description |
---|---|
static String |
SERVICE_NAME |
Constructor and Description |
---|
TransactionManagerServiceImpl(NodeEngineImpl nodeEngine) |
Modifier and Type | Method and Description |
---|---|
void |
clientDisconnected(String clientUuid)
Invoked when a client disconnects from a member.
|
void |
createAllowedDuringPassiveStateBackupLog(String callerUuid,
String txnId) |
void |
createBackupLog(String callerUuid,
String txnId) |
<T> T |
executeTransaction(TransactionOptions options,
TransactionalTask<T> task) |
String |
getGroupName() |
void |
init(NodeEngine nodeEngine,
Properties properties)
Initializes this ManagedService
|
void |
memberAdded(MembershipServiceEvent event)
Invoked when a new member is added to the cluster.
|
void |
memberAttributeChanged(MemberAttributeServiceEvent event)
Invoked when a member attribute is changed.
|
void |
memberRemoved(MembershipServiceEvent event)
Invoked when an existing member leaves the cluster.
|
Transaction |
newAllowedDuringPassiveStateTransaction(TransactionOptions options)
Creates a plain transaction object which can be used while cluster state is
ClusterState.PASSIVE ,
without wrapping it inside a TransactionContext. |
TransactionContext |
newClientTransactionContext(TransactionOptions options,
String clientUuid) |
Transaction |
newTransaction(TransactionOptions options)
Creates a plain transaction object, without wrapping it
inside a TransactionContext.
|
TransactionContext |
newTransactionContext(TransactionOptions options) |
void |
purgeBackupLog(String txnId) |
void |
replicaBackupLog(List<TransactionLogRecord> records,
String callerUuid,
String txnId,
long timeoutMillis,
long startTime) |
void |
reset()
reset this ManagedService back to initial state.
|
void |
rollbackBackupLog(String txnId) |
void |
shutdown(boolean terminate)
Shuts down this ManagedService.
|
public static final String SERVICE_NAME
public TransactionManagerServiceImpl(NodeEngineImpl nodeEngine)
public String getGroupName()
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 Transaction newTransaction(TransactionOptions options)
options
- transaction optionspublic Transaction newAllowedDuringPassiveStateTransaction(TransactionOptions options)
ClusterState.PASSIVE
,
without wrapping it inside a TransactionContext.
Also see newTransaction(TransactionOptions)
for more detailsoptions
- transaction optionsClusterState.PASSIVE
public void init(NodeEngine nodeEngine, Properties properties)
ManagedService
init
in interface ManagedService
nodeEngine
- the NodeEngine that this ManagedService belongs to.properties
- the Properties. Can be used to pass settings to the service.public void reset()
ManagedService
reset
in interface ManagedService
public void shutdown(boolean terminate)
ManagedService
shutdown
in interface ManagedService
terminate
- true to shut down the ManagedServicepublic void memberAdded(MembershipServiceEvent event)
MembershipAwareService
memberAdded
in interface MembershipAwareService
event
- the event for a new member added to the clusterpublic void memberRemoved(MembershipServiceEvent event)
MembershipAwareService
memberRemoved
in interface MembershipAwareService
event
- the event for an existing member leaving the clusterpublic void memberAttributeChanged(MemberAttributeServiceEvent event)
MembershipAwareService
memberAttributeChanged
in interface MembershipAwareService
event
- the event for a member attribute being changedpublic void clientDisconnected(String clientUuid)
ClientAwareService
clientDisconnected
in interface ClientAwareService
clientUuid
- the Uuid of the client that disconnected from a memberpublic void createAllowedDuringPassiveStateBackupLog(String callerUuid, String txnId)
public void replicaBackupLog(List<TransactionLogRecord> records, String callerUuid, String txnId, long timeoutMillis, long startTime)
public void rollbackBackupLog(String txnId)
public void purgeBackupLog(String txnId)
Copyright © 2016 Hazelcast, Inc.. All Rights Reserved.