Skip to content

D
device-new-platform
Commit d9389226 authored by 赵啸非's avatar 赵啸非
Browse files
Options

添加前端页面

parent ff6ae83e
Show whitespace changes
Inline Side-by-side
Showing with 1 addition and 1 deletion
common-lib/src/main/java/com/mortals/xhx/queue/rabbitmq/TbRabbitMqConsumerTemplate.java
View file @ d9389226
...@@ -55,7 +55,7 @@ public class TbRabbitMqConsumerTemplate<T extends TbQueueMsg> extends AbstractTb ...@@ -55,7 +55,7 @@ public class TbRabbitMqConsumerTemplate<T extends TbQueueMsg> extends AbstractTb
.map(queue -> { .map(queue -> {
try { try {
AMQP.Queue.DeclareOk declareOk = channel.queueDeclarePassive(queue); AMQP.Queue.DeclareOk declareOk = channel.queueDeclarePassive(queue);
log.info("declareOk:{}",JSON.toJSONString(declareOk)); //log.info("declareOk:{}",JSON.toJSONString(declareOk));
GetResponse getResponse = channel.basicGet(queue, true); GetResponse getResponse = channel.basicGet(queue, true);
return getResponse; return getResponse;
} catch (IOException e) { } catch (IOException e) {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment