增加华为广告控制

admin

2020-07-02 a62d474f024332dde7616054c549b7794f120151

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
package com.yeshi.fanli.util.rocketmq.consumer; 
 
import java.io.UnsupportedEncodingException; 
import java.util.List; 
 
import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext; 
import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyStatus; 
import org.apache.rocketmq.client.consumer.listener.MessageListenerConcurrently; 
import org.apache.rocketmq.common.message.MessageExt; 
import org.springframework.stereotype.Component; 
 
@Component 
public class TestRocketMQCosumer implements MessageListenerConcurrently { 
 
    @Override 
    public ConsumeConcurrentlyStatus consumeMessage(List<MessageExt> arg0, ConsumeConcurrentlyContext arg1) { 
        for (MessageExt msg : arg0) { 
            try { 
                System.out.println(new String(msg.getBody(), "UTF-8")); 
            } catch (UnsupportedEncodingException e) { 
                e.printStackTrace(); 
            } 
        } 
        return ConsumeConcurrentlyStatus.CONSUME_SUCCESS; 
    } 
 
}