blame | 历史 | 补丁 | 提交 | 提交对比 | show whitespace
admin
2024-10-30 010ef2a907e66efd4702443c06cdd18f8a7ffa5b 
 src/main/java/com/yeshi/buwan/util/mq/rabbit/consumer/VideoUpdatePPTVListener.java


@@ -11,7 +11,7 @@


import org.slf4j.LoggerFactory;


import org.springframework.amqp.core.Message;


import org.springframework.amqp.rabbit.core.RabbitTemplate;


import org.springframework.stereotype.Component;


import org.springframework.amqp.rabbit.listener.api.ChannelAwareMessageListener;




import javax.annotation.Resource;


import java.nio.charset.StandardCharsets;


@@ -22,8 +22,7 @@


 * @description:


 * @date 2024/9/26 13:47


 */


@Component


public class VideoUpdatePPTVListener {


public class VideoUpdatePPTVListener   implements ChannelAwareMessageListener {


    private final static Logger logger = LoggerFactory.getLogger(VideoUpdatePPTVListener.class);




    @Resource


@@ -31,7 +30,7 @@




    @Resource


    private PPTVService pptvService;




    @Override


    public void onMessage(Message message, Channel channel) throws Exception {


        RabbitmqMsgConsumeUtil.processMessage(message, channel, rabbitTemplate, () -> {


            String result = new String(message.getBody(), StandardCharsets.UTF_8);