CMQ转为Rabbitmq

admin

2024-10-17 b30fb8afd3cd6228bda9b182dc412bb3c8daf69c

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
package com.yeshi.buwan.util.mq.rabbit;
 
import org.springframework.amqp.core.Message;
import org.springframework.amqp.core.MessageListener;
 
import java.io.UnsupportedEncodingException;
 
/**
 * @author hxh
 * @title: QueueHelloWorldListener
 * @description: 测试消息
 * @date 2024/9/26 13:47
 */
public class QueueHelloWorldListener implements MessageListener {
    @Override
    public void onMessage(Message message) {
        try {
            System.out.println("收到消息："+ new String(message.getBody(),"UTF-8"));
        } catch (UnsupportedEncodingException e) {
            e.printStackTrace();
        }
    }
}