抖音转链修改

admin

2024-01-23 81da61b828e29b7745e1382dfbbaeb685dc083ef

 fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/TestRocketMQCosumer.java

@@ -1,27 +1,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;

   }



}

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;
   }

}