zeaslity/ProjectOctopus
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

[agent][init]- fix bugs

Browse Source
This commit is contained in:
zeaslity
2023-02-28 10:34:48 +08:00
parent 593d5c1b77
commit f43d9f84a4
3 changed files with 24 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
agent/src/main/java/io/wdd/agent/initialization/bootup/OctopusAgentInitService.java
View File

@@ -9,7 +9,6 @@ import io.wdd.common.beans.rabbitmq.OctopusMessage;
import io.wdd.common.handler.MyRuntimeException;
import lombok.SneakyThrows;
import lombok.extern.slf4j.Slf4j;
import org.checkerframework.checker.units.qual.K;
import org.springframework.amqp.core.Message;
import org.springframework.amqp.rabbit.annotation.*;
import org.springframework.amqp.support.AmqpHeaders;
@@ -88,7 +87,9 @@ public class OctopusAgentInitService {
// response chain to handle all kind of type of octopus message
if (!octopusMessageHandler.handle(octopusMessage)) {
throw new MyRuntimeException(" Handle Octopus Message Error !");
String s = "Handle Octopus Message Error !";
log.error(s);
throw new MyRuntimeException(s);
}
} catch (Exception e) {
@@ -98,8 +99,7 @@ public class OctopusAgentInitService {
// long deliveryTag, boolean requeue
// channel.basicReject(deliveryTag,true);
log.error("Octopus Agent Initialization Error, please check !");
log.info("waiting for 5 seconds");
log.error("Octopus Agent Initialization Error, please check ! Waiting for 5 seconds");
// 这里只是便于出现死循环时查看
TimeUnit.SECONDS.sleep(5);

7
agent/src/main/java/io/wdd/agent/initialization/message/GenOctopusRabbitMQConnection.java
View File

@@ -49,8 +49,11 @@ public class GenOctopusRabbitMQConnection {
// reboot judgement of existing exchange
QueueInformation queueInfo = rabbitAdmin.getQueueInfo(agentTopicName);
if (ObjectUtils.isNotEmpty(queueInfo) && queueInfo.getConsumerCount() > 0 ) {
log.info("Octopus Agent Specific Topic Queue Already Existed ! == {}", agentTopicName);
if (ObjectUtils.isNotEmpty(queueInfo)) {
log.info(
"Octopus Agent Specific Topic Queue Already Existed ! == {}",
agentTopicName
);
return;
}