io.shardingsphere.transaction.storage.impl

Class MemoryTransactionLogStorage

java.lang.Object

io.shardingsphere.transaction.storage.impl.MemoryTransactionLogStorage

All Implemented Interfaces:

TransactionLogStorage

public final class MemoryTransactionLogStorage
extends Object
implements TransactionLogStorage

Transaction log memory storage.

Author:

zhangliang

Constructor Summary

Constructors

Constructor and Description
MemoryTransactionLogStorage()

Method Summary

Modifier and Type	Method and Description
void	add(TransactionLog transactionLog) Save transaction log.
List<TransactionLog>	findEligibleTransactionLogs(int size, int maxDeliveryTryTimes, long maxDeliveryTryDelayMillis) Find eligible transaction logs.
void	increaseAsyncDeliveryTryTimes(String id) Increase asynchronized delivery try times.
boolean	processData(Connection connection, TransactionLog transactionLog, int maxDeliveryTryTimes) Process transaction logs.
void	remove(String id) Remove transaction log.

Methods inherited from class java.lang.Object

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

Constructor Detail

MemoryTransactionLogStorage

public MemoryTransactionLogStorage()

Method Detail

add

public void add(TransactionLog transactionLog)

Description copied from interface: TransactionLogStorage

Save transaction log.

Specified by:

add in interface TransactionLogStorage

Parameters:

transactionLog - transaction log

remove

public void remove(String id)

Description copied from interface: TransactionLogStorage

Remove transaction log.

Specified by:

remove in interface TransactionLogStorage

Parameters:

id - transaction log id

findEligibleTransactionLogs

public List<TransactionLog> findEligibleTransactionLogs(int size,
                                                        int maxDeliveryTryTimes,
                                                        long maxDeliveryTryDelayMillis)

Description copied from interface: TransactionLogStorage

Find eligible transaction logs.

To be processed transaction logs:

1. retry times less than max retry times.

2. transaction log last retry timestamp interval early than last retry timestamp.

Specified by:

findEligibleTransactionLogs in interface TransactionLogStorage

Parameters:

size - size of fetch transaction log

maxDeliveryTryTimes - max delivery try times

maxDeliveryTryDelayMillis - max delivery try delay millis

Returns:

eligible transaction logs

increaseAsyncDeliveryTryTimes

public void increaseAsyncDeliveryTryTimes(String id)

Description copied from interface: TransactionLogStorage

Increase asynchronized delivery try times.

Specified by:

increaseAsyncDeliveryTryTimes in interface TransactionLogStorage

Parameters:

id - transaction log id

processData

public boolean processData(Connection connection,
                           TransactionLog transactionLog,
                           int maxDeliveryTryTimes)

Description copied from interface: TransactionLogStorage

Process transaction logs.

Specified by:

processData in interface TransactionLogStorage

Parameters:

connection - connection for business app

transactionLog - transaction log

maxDeliveryTryTimes - max delivery try times

Returns:

process success or not