Skip to content

Commit 82f38ed

Browse files
committed
feat: 事务消息重试添加改为非 OVER 状态
1 parent df070e6 commit 82f38ed

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

  • framework/framework_base/src/main/java/com/github/cadecode/uniboot/framework/base/plugin/handler

framework/framework_base/src/main/java/com/github/cadecode/uniboot/framework/base/plugin/handler/MqTxMsgHandler.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -71,7 +71,7 @@ public void doRetry() {
7171
Date currDate = new Date();
7272
List<PlgMqMsg> msgList = mqMsgService.lambdaQuery()
7373
.le(PlgMqMsg::getNextRetryTime, currDate)
74-
.eq(PlgMqMsg::getSendState, SendStateEnum.FAIL)
74+
.ne(PlgMqMsg::getSendState, SendStateEnum.OVER)
7575
.gt(PlgMqMsg::getLeftRetryTimes, 0)
7676
.list();
7777
if (ObjectUtil.isEmpty(msgList)) {

0 commit comments

Comments
 (0)