Skip to content

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

修改消息组件

parent 7c34dc11
Hide whitespace changes
Inline Side-by-side
Showing with 2 additions and 2 deletions
common-lib/src/main/java/com/mortals/xhx/queue/rabbitmq/TbRabbitMqProducerTemplate.java
View file @ 886487d5
......@@ -85,7 +85,7 @@ public class TbRabbitMqProducerTemplate<T extends TbQueueMsg> implements TbQueue
//topic不存在创建通道队列
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", Integer.parseInt(rabbitMqSettings.getMessageTtl()));
channel.queueDeclare(tpi.getTopic(), true, false, false, null);
}
if (!innerExists(tpi.getExchangeName(), channel)) {
......@@ -137,7 +137,7 @@ public class TbRabbitMqProducerTemplate<T extends TbQueueMsg> implements TbQueue
//topic不存在创建通道队列
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", Integer.parseInt(rabbitMqSettings.getMessageTtl()));
channel.queueDeclare(tpi.getTopic(), true, false, false, args);
}
if (!innerExists(tpi.getExchangeName(), channel)) {
......
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