diff --git a/pom.xml b/pom.xml
index ddf5b5a..8a0c268 100644
--- a/pom.xml
+++ b/pom.xml
@@ -6,8 +6,8 @@
io.github.sinri
Keel
-
- 3.2.7
+
+ 3.2.8
Keel
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 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 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 getIssueRecorder() {
@Override
public final void start(Promise startPromise) {
this.issueRecorder = buildIssueRecorder();
- this.start();
+ startAsKeelVerticle(startPromise);
}
@Override
public final void start() {
+ this.issueRecorder = buildIssueRecorder();
this.startAsKeelVerticle();
}