rocketmq修改

admin

2019-10-22 16f3c0a66181095ff4d353ebe78fbaa30a36a3d3

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
package com.yeshi.fanli.util.rocketmq.order; 
 
import org.springframework.stereotype.Component; 
 
import com.aliyun.openservices.ons.api.Message; 
import com.aliyun.openservices.ons.api.transaction.LocalTransactionChecker; 
import com.aliyun.openservices.ons.api.transaction.TransactionStatus; 
 
@Component 
public class RocketMQLocalOrderTransactionChecker implements LocalTransactionChecker { 
    public RocketMQLocalOrderTransactionChecker() { 
 
    } 
 
    @Override 
    public TransactionStatus check(Message msg) { 
        if (msg.getTag().startsWith("orderhongbao-")) {// 订单加入红包标识 
            return TransactionStatus.CommitTransaction; 
        } 
        return TransactionStatus.Unknow; 
    } 
}