Commit 4ceb5e95 authored by 赵啸非's avatar 赵啸非

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

parent 6b787efe
...@@ -84,7 +84,7 @@ public class TbRabbitMqProducerTemplate<T extends TbQueueMsg> implements TbQueue ...@@ -84,7 +84,7 @@ public class TbRabbitMqProducerTemplate<T extends TbQueueMsg> implements TbQueue
try { try {
if (!topicIfNotExist) { if (!topicIfNotExist) {
//topic不存在创建通道队列 //topic不存在创建通道队列
log.info("queueDeclareAdd==>exchangeName:{} topic:{}",tpi.getExchangeName(),tpi.getTopic()); log.info("sendQueueDeclareAdd==>exchangeName:{} topic:{}",tpi.getExchangeName(),tpi.getTopic());
Map<String, Object> args = new HashMap<>(); Map<String, Object> args = new HashMap<>();
args.put("x-message-ttl", Integer.parseInt(rabbitMqSettings.getMessageTtl())); args.put("x-message-ttl", Integer.parseInt(rabbitMqSettings.getMessageTtl()));
channel.queueDeclare(tpi.getTopic(), true, false, false, args); channel.queueDeclare(tpi.getTopic(), true, false, false, args);
...@@ -133,17 +133,18 @@ public class TbRabbitMqProducerTemplate<T extends TbQueueMsg> implements TbQueue ...@@ -133,17 +133,18 @@ public class TbRabbitMqProducerTemplate<T extends TbQueueMsg> implements TbQueue
public void queueDeclare(TopicPartitionInfo tpi, TbQueueCallback callback) { public void queueDeclare(TopicPartitionInfo tpi, TbQueueCallback callback) {
Boolean topicIfNotExist = createTopicIfNotExist(tpi); Boolean topicIfNotExist = createTopicIfNotExist(tpi);
try { try {
if (!innerExists(tpi.getExchangeName(), channel)) {
//判断交换机是否存在,如果不存在则创建后与新加入的队列绑定
channel = connection.createChannel();
channel.exchangeDeclare(tpi.getExchangeName(), BuiltinExchangeType.DIRECT, true, false, null);
}
if (!topicIfNotExist) { if (!topicIfNotExist) {
//topic不存在创建通道队列 //topic不存在创建通道队列
log.info("queueDeclareAdd==>exchangeName:{} topic:{}",tpi.getExchangeName(),tpi.getTopic()); log.info("queueDeclareAdd==>exchangeName:{} topic:{}",tpi.getExchangeName(),tpi.getTopic());
Map<String, Object> args = new HashMap<>(); Map<String, Object> args = new HashMap<>();
args.put("x-message-ttl", Integer.parseInt(rabbitMqSettings.getMessageTtl())); args.put("x-message-ttl", Integer.parseInt(rabbitMqSettings.getMessageTtl()));
channel.queueDeclare(tpi.getTopic(), true, false, false, args); channel.queueDeclare(tpi.getTopic(), true, false, false, args);
} channel.queueBind(tpi.getTopic(), tpi.getExchangeName(), tpi.getTopic());
if (!innerExists(tpi.getExchangeName(), channel)) {
//判断交换机是否存在,如果不存在则创建后与新加入的队列绑定
channel = connection.createChannel();
channel.exchangeDeclare(tpi.getExchangeName(), BuiltinExchangeType.DIRECT, true, false, null);
} }
// callback.onSuccess(new RabbitQueueMsgMetadata()); // callback.onSuccess(new RabbitQueueMsgMetadata());
......
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