io.openmessaging.producer

Interface LocalTransactionExecutor

public interface LocalTransactionExecutor

Each executor will be associated with a transactional message, can be used to execute local transaction branch and submit the transaction status(commit or rollback).

The associated message will be exposed to consumer when the local transaction has been committed, or be discarded if local transaction has been rolled back.

If the executor doesn't submit the transaction status for a long time, the server may lookup it forwardly through check(Message, CheckContext)

Since:

OMS 1.0.0

Version:

OMS 1.0.0

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	LocalTransactionExecutor.CheckContext
static interface	LocalTransactionExecutor.ExecutionContext

Method Summary

Modifier and Type	Method and Description
void	check(Message message, LocalTransactionExecutor.CheckContext context) Checks the status of the local transaction branch.
void	execute(Message message, LocalTransactionExecutor.ExecutionContext context) Executes the local transaction branch after the message is sent successfully, and submits the status whether the transaction was successfully committed or rolled back.

Method Detail

execute

void execute(Message message,
             LocalTransactionExecutor.ExecutionContext context)

Executes the local transaction branch after the message is sent successfully, and submits the status whether the transaction was successfully committed or rolled back.

Parameters:

message - the associated message

context - the execution context

check

void check(Message message,
           LocalTransactionExecutor.CheckContext context)

Checks the status of the local transaction branch.

Parameters:

message - the associated message

context - the check context