Skip to content

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

修改消息组件

parent 28c5d1e4
Hide whitespace changes
Inline Side-by-side
Showing with 2 additions and 0 deletions
common-lib/src/main/java/com/mortals/xhx/queue/rabbitmq/TbRabbitMqProducerTemplate.java
View file @ 7c34dc11
...@@ -84,6 +84,7 @@ public class TbRabbitMqProducerTemplate<T extends TbQueueMsg> implements TbQueue ...@@ -84,6 +84,7 @@ public class TbRabbitMqProducerTemplate<T extends TbQueueMsg> implements TbQueue
if (!topicIfNotExist) { if (!topicIfNotExist) {
//topic不存在创建通道队列 //topic不存在创建通道队列
Map<String, Object> args = new HashMap<>(); Map<String, Object> args = new HashMap<>();
log.info("x-message-ttl:{}",rabbitMqSettings.getMessageTtl());
args.put("x-message-ttl", rabbitMqSettings.getMessageTtl()); args.put("x-message-ttl", rabbitMqSettings.getMessageTtl());
channel.queueDeclare(tpi.getTopic(), true, false, false, null); channel.queueDeclare(tpi.getTopic(), true, false, false, null);
} }
...@@ -135,6 +136,7 @@ public class TbRabbitMqProducerTemplate<T extends TbQueueMsg> implements TbQueue ...@@ -135,6 +136,7 @@ public class TbRabbitMqProducerTemplate<T extends TbQueueMsg> implements TbQueue
if (!topicIfNotExist) { if (!topicIfNotExist) {
//topic不存在创建通道队列 //topic不存在创建通道队列
Map<String, Object> args = new HashMap<>(); Map<String, Object> args = new HashMap<>();
log.info("x-message-ttl:{}",rabbitMqSettings.getMessageTtl());
args.put("x-message-ttl", rabbitMqSettings.getMessageTtl()); args.put("x-message-ttl", rabbitMqSettings.getMessageTtl());
channel.queueDeclare(tpi.getTopic(), true, false, false, args); channel.queueDeclare(tpi.getTopic(), true, false, false, args);
} }
......
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