From b5570e78cc9d30cbaaedc8c5c5f7b7c4a7821079 Mon Sep 17 00:00:00 2001
From: sinri <e.joshua.s.e@gmail.com>
Date: Tue, 21 May 2024 12:02:37 +0800
Subject: [PATCH] 3.2.8 Fix Bug in 3.2.7

Signed-off-by: sinri <e.joshua.s.e@gmail.com>
---
 pom.xml                                                       | 4 ++--
 .../java/io/github/sinri/keel/servant/queue/KeelQueue.java    | 4 +++-
 .../github/sinri/keel/servant/queue/QueueTaskIssueRecord.java | 2 +-
 .../sinri/keel/verticles/KeelVerticleImplWithEventLogger.java | 4 ++--
 .../keel/verticles/KeelVerticleImplWithIssueRecorder.java     | 3 ++-
 5 files changed, 10 insertions(+), 7 deletions(-)

diff --git a/pom.xml b/pom.xml
index ddf5b5a..8a0c268 100644
--- a/pom.xml
+++ b/pom.xml
@@ -6,8 +6,8 @@
 
     <groupId>io.github.sinri</groupId>
     <artifactId>Keel</artifactId>
-    <!--    <version>3.2.7-SNAPSHOT</version>-->
-    <version>3.2.7</version>
+    <!--        <version>3.2.8-SNAPSHOT</version>-->
+    <version>3.2.8</version>
 
     <name>Keel</name>
     <description>
diff --git a/src/main/java/io/github/sinri/keel/servant/queue/KeelQueue.java b/src/main/java/io/github/sinri/keel/servant/queue/KeelQueue.java
index caf77be..c724a8e 100644
--- a/src/main/java/io/github/sinri/keel/servant/queue/KeelQueue.java
+++ b/src/main/java/io/github/sinri/keel/servant/queue/KeelQueue.java
@@ -137,7 +137,9 @@ private Future<Void> whenSignalRunCame(KeelQueueNextTaskSeeker nextTaskSeeker) {
                                 task.setQueueWorkerPoolManager(this.queueWorkerPoolManager);
 
                                 return Future.succeededFuture()
-                                        .compose(v -> task.deployMe(new DeploymentOptions().setThreadingModel(ThreadingModel.WORKER)))
+                                        .compose(v -> task.deployMe(new DeploymentOptions()
+                                                .setThreadingModel(ThreadingModel.WORKER)
+                                        ))
                                         .compose(
                                                 deploymentID -> {
                                                     getIssueRecorder().info(r -> r.message("TASK [" + task.getTaskReference() + "] VERTICLE DEPLOYED: " + deploymentID));
diff --git a/src/main/java/io/github/sinri/keel/servant/queue/QueueTaskIssueRecord.java b/src/main/java/io/github/sinri/keel/servant/queue/QueueTaskIssueRecord.java
index aa2ff67..4b11763 100644
--- a/src/main/java/io/github/sinri/keel/servant/queue/QueueTaskIssueRecord.java
+++ b/src/main/java/io/github/sinri/keel/servant/queue/QueueTaskIssueRecord.java
@@ -11,6 +11,7 @@ public final class QueueTaskIssueRecord extends BaseIssueRecord<QueueTaskIssueRe
     public static final String TopicQueue = "Queue";
 
     public QueueTaskIssueRecord(@Nonnull String taskReference, @Nonnull String taskCategory) {
+        super();
         this.classification("task", "reference:" + taskReference, "category:" + taskCategory);
     }
 
@@ -25,5 +26,4 @@ public String topic() {
     public QueueTaskIssueRecord getImplementation() {
         return this;
     }
-
 }
diff --git a/src/main/java/io/github/sinri/keel/verticles/KeelVerticleImplWithEventLogger.java b/src/main/java/io/github/sinri/keel/verticles/KeelVerticleImplWithEventLogger.java
index 90a125a..500d08f 100644
--- a/src/main/java/io/github/sinri/keel/verticles/KeelVerticleImplWithEventLogger.java
+++ b/src/main/java/io/github/sinri/keel/verticles/KeelVerticleImplWithEventLogger.java
@@ -27,12 +27,12 @@ public KeelEventLogger getLogger() {
     @Override
     public final void start(Promise<Void> startPromise) {
         this.logger = buildEventLogger();
-        start();
-        startPromise.complete();
+        startAsKeelVerticle(startPromise);
     }
 
     @Override
     public final void start() {
+        this.logger = buildEventLogger();
         this.startAsKeelVerticle();
     }
 
diff --git a/src/main/java/io/github/sinri/keel/verticles/KeelVerticleImplWithIssueRecorder.java b/src/main/java/io/github/sinri/keel/verticles/KeelVerticleImplWithIssueRecorder.java
index e8bfa4c..b666270 100644
--- a/src/main/java/io/github/sinri/keel/verticles/KeelVerticleImplWithIssueRecorder.java
+++ b/src/main/java/io/github/sinri/keel/verticles/KeelVerticleImplWithIssueRecorder.java
@@ -24,11 +24,12 @@ public KeelIssueRecorder<T> getIssueRecorder() {
     @Override
     public final void start(Promise<Void> startPromise) {
         this.issueRecorder = buildIssueRecorder();
-        this.start();
+        startAsKeelVerticle(startPromise);
     }
 
     @Override
     public final void start() {
+        this.issueRecorder = buildIssueRecorder();
         this.startAsKeelVerticle();
     }