[agent][ init]- fix bug

agent/src/main/java/io/wdd/agent/initialization/message/GenOctopusRabbitMQConnection.java

@@ -48,20 +48,22 @@ public class GenOctopusRabbitMQConnection {
 
         // reboot judgement of existing exchange
         QueueInformation queueInfo = rabbitAdmin.getQueueInfo(agentTopicName);
-
+        if (ObjectUtils.isEmpty(queueInfo)) {
-        if (ObjectUtils.isNotEmpty(queueInfo)) {
+            log.debug("开始为Agent创建相形的消息队列！");
-            log.info(
-                    "Octopus Agent Specific Topic Queue Already Existed ! == {}",
-                    agentTopicName
-            );
-            return;
         }
 
-        Queue queue = new Queue(agentTopicName, true, false, false);
+        Queue queue = new Queue(
+                agentTopicName,
+                true,
+                false,
+                false
+        );
         Binding binding = new Binding(
                 agentTopicName,
                 Binding.DestinationType.QUEUE,
-                octopusMessage.getContent().toString(),
+                octopusMessage
+                        .getContent()
+                        .toString(),
                 agentTopicName + "*",
                 null
         );
@@ -77,8 +79,7 @@ public class GenOctopusRabbitMQConnection {
         listenerContainer.setMessageListener(this::AgentListenToSpecificTopicOctopusMessage);
         listenerContainer.start();
 
-
+        log.info("每个Agent特定的Octopus Topic Queue创建成功!");
-        log.info("Specific Octopus Topic Queue Generate Successfully !");
         messageListenerContainerList.add(listenerContainer);
     }