版本迭代
This commit is contained in:
parent
112733abfe
commit
d12a283082
|
@ -13,7 +13,7 @@ public class MessageConsumer {
|
||||||
|
|
||||||
//测试消费kafka
|
//测试消费kafka
|
||||||
// 监听队列 "myQueue"
|
// 监听队列 "myQueue"
|
||||||
@RabbitListener(queues = "myQueue")
|
// @RabbitListener(queues = "myQueue")
|
||||||
public void receiveMessage(JSONObject message) {
|
public void receiveMessage(JSONObject message) {
|
||||||
try {
|
try {
|
||||||
// 处理接收到的消息
|
// 处理接收到的消息
|
||||||
|
|
Loading…
Reference in New Issue