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
23
24
25
26
27
28
29
30
package com.yeshi.fanli.util.rocketmq.consumer.order; 
 
import org.springframework.stereotype.Component; 
 
import com.aliyun.openservices.ons.api.Action; 
import com.aliyun.openservices.ons.api.ConsumeContext; 
import com.aliyun.openservices.ons.api.Message; 
import com.aliyun.openservices.ons.api.MessageListener; 
 
/** 
 * 邀请订单补贴消息消费 
 *  
 * @author Administrator 
 * 
 */ 
@Component 
public class InviteOrderSubsidyMessageListener implements MessageListener { 
 
    public InviteOrderSubsidyMessageListener() { 
 
    } 
 
    @Override 
    public Action consume(Message message, ConsumeContext context) { 
        if (message.getTag().startsWith("")) { 
 
        } 
        return Action.CommitMessage; 
    } 
}