o Adding an ActiveMQ connection to messages can be sent as a hint to the consumer.HEADmaster

1 files changed, 0 insertions, 10 deletions

diff --git a/src/main/java/io/trygvis/async/JdbcAsyncService.java b/src/main/java/io/trygvis/async/JdbcAsyncService.java
index 57ab5c6..46f1f30 100644
--- a/src/main/java/io/trygvis/async/JdbcAsyncService.java
+++ b/src/main/java/io/trygvis/async/JdbcAsyncService.java
@@ -1,14 +1,10 @@
 package io.trygvis.async;
 
-import io.trygvis.queue.JdbcQueueService;
 import io.trygvis.queue.QueueExecutor;
 import io.trygvis.queue.QueueService;
 import io.trygvis.queue.QueueSystem;
 import io.trygvis.queue.Task;
-import io.trygvis.queue.TaskDao;
 import io.trygvis.queue.TaskEffect;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
 
 import java.sql.Connection;
 import java.sql.SQLException;
@@ -19,16 +15,12 @@ import static java.lang.System.currentTimeMillis;
 import static java.lang.Thread.sleep;
 
 public class JdbcAsyncService {
-    private final Logger log = LoggerFactory.getLogger(getClass());
-
     private final Map<String, QueueController> queues = new HashMap<>();
 
     private final QueueSystem queueSystem;
-    private final JdbcQueueService queueService;
 
     public JdbcAsyncService(QueueSystem queueSystem) {
         this.queueSystem = queueSystem;
-        this.queueService = queueSystem.createQueueService();
     }
 
     public synchronized QueueController registerQueue(QueueExecutor queue, QueueService.TaskExecutionRequest req, TaskEffect processor) {
@@ -40,8 +32,6 @@ public class JdbcAsyncService {
 
         queues.put(queue.queue.name, queueController);
 
-        log.info("registerQueue: LEAVE");
-
         return queueController;
     }