Commit 6b787efe authored by 赵啸非's avatar 赵啸非

修改用户登录,权限分配等

parent 2cc4fcb5
......@@ -135,6 +135,7 @@ public class TbRabbitMqProducerTemplate<T extends TbQueueMsg> implements TbQueue
try {
if (!topicIfNotExist) {
//topic不存在创建通道队列
log.info("queueDeclareAdd==>exchangeName:{} topic:{}",tpi.getExchangeName(),tpi.getTopic());
Map<String, Object> args = new HashMap<>();
args.put("x-message-ttl", Integer.parseInt(rabbitMqSettings.getMessageTtl()));
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