Commit 04072071 authored by 赵啸非's avatar 赵啸非

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

parent 39713cb6
......@@ -36,9 +36,6 @@ public class TbRabbitMqConsumerTemplate<T extends TbQueueMsg> extends AbstractTb
private Channel channel;
private Connection connection;
/**
* rabbmit设置
*/
private TbRabbitMqSettings rabbitMqSettings;
private volatile Set<String> queues=new HashSet<>();
......@@ -91,11 +88,7 @@ public class TbRabbitMqConsumerTemplate<T extends TbQueueMsg> extends AbstractTb
topicNames.stream().forEach(topic->{
queues.add(topic);
});
// queues = partitions.stream()
// .map(TopicPartitionInfo::getFullTopicName)
// .collect(Collectors.toSet());
log.info("doSubscribe:{},topicNames:{}", JSON.toJSONString(queues), JSON.toJSONString(queues));
log.info("doSubscribe:{}", JSON.toJSONString(queues));
}
@Override
......
......@@ -84,6 +84,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