diff --git a/application/consumer-activemq-quarkus/src/main/java/webapp/tier/service/ActiveMqSubscribeService.java b/application/consumer-activemq-quarkus/src/main/java/webapp/tier/service/ActiveMqSubscribeService.java index 496008a2b..5384dce65 100644 --- a/application/consumer-activemq-quarkus/src/main/java/webapp/tier/service/ActiveMqSubscribeService.java +++ b/application/consumer-activemq-quarkus/src/main/java/webapp/tier/service/ActiveMqSubscribeService.java @@ -51,6 +51,7 @@ public static void stopReceived() { ActiveMqSubscribeService.isEnableReceived = false; } + @Override public void run() { while (isEnableReceived) { try (JMSContext context = connectionFactory