test/Raincat
1
0
Fork 0
mirror of https://gitee.com/dromara/Raincat.git synced 2024-12-02 03:48:35 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

bug

Browse Source
This commit is contained in:
xiaoyu1 2018-06-29 11:10:31 +08:00
parent 7cc9c2e53d
commit aa33221ae5
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
raincat-core/src/main/java/com/raincat/core/spi/repository/RedisTransactionRecoverRepository.java
View File

@ -130,7 +130,7 @@ public class RedisTransactionRecoverRepository implements TransactionRecoverRepo
final List<TransactionRecover> tccTransactions = listAll();
return tccTransactions
.stream()
.filter(transactionRecover -> transactionRecover.getLastTime().compareTo(date) > 0)
.filter(transactionRecover -> transactionRecover.getLastTime().compareTo(date) < 0)
.collect(Collectors.toList());
}

2
raincat-core/src/main/java/com/raincat/core/spi/repository/ZookeeperTransactionRecoverRepository.java
View File

@ -145,7 +145,7 @@ public class ZookeeperTransactionRecoverRepository implements TransactionRecover
public List<TransactionRecover> listAllByDelay(final Date date) {
final List<TransactionRecover> tccTransactions = listAll();
return tccTransactions.stream()
.filter(transactionRecover -> transactionRecover.getLastTime().compareTo(date) > 0)
.filter(transactionRecover -> transactionRecover.getLastTime().compareTo(date) < 0)
.collect(Collectors.toList());
}