1 files changed, 14 insertions, 7 deletions
diff --git a/src/main/java/io/trygvis/Main.java b/src/main/java/io/trygvis/Main.java
index aafb728..448c3e4 100755
--- a/src/main/java/io/trygvis/Main.java
+++ b/src/main/java/io/trygvis/Main.java
@@ -7,12 +7,12 @@ import org.slf4j.bridge.*;
 import org.springframework.beans.factory.annotation.*;
 import org.springframework.context.support.*;
 import org.springframework.stereotype.*;
-import org.springframework.transaction.annotation.*;
+
+import java.util.*;
 
 import static java.lang.System.*;
 
 @Component
-@Transactional
 public class Main {
     private static final Logger log = LoggerFactory.getLogger(Main.class);
 
@@ -23,7 +23,7 @@ public class Main {
         setProperty("database.url", getProperty("jdbc.url", "jdbc:postgresql://localhost/" + username));
         setProperty("database.username", username);
         setProperty("database.password", username);
-        setProperty("hibernate.showSql", "true");
+//        setProperty("hibernate.showSql", "true");
         setProperty("hibernate.hbm2ddl.auto", "create"); // create
         setProperty("hibernate.dialect", PostgreSQL82Dialect.class.getName());
 
@@ -50,19 +50,26 @@ public class Main {
     private AsyncService<AsyncService.QueueRef, AsyncService.ExecutionRef> asyncService;
 
     @Autowired
-    private CreateArticleCallable createArticleCallable;
+    @Qualifier("createArticle")
+    private AsyncService.AsyncCallable createArticleCallable;
 
     @Autowired
-    private UpdateArticeCallable updateArticeCallable;
+    @Qualifier("createArticle")
+    private AsyncService.AsyncCallable/*UpdateArticleCallable*/ updateArticleCallable;
 
     public void run() throws Exception {
         log.info("Main.run");
 
-        asyncService.registerQueue("create-queue", 1, createArticleCallable);
+        JpaAsyncService.JpaQueueRef queueRef = asyncService.registerQueue("create-queue", 10, createArticleCallable);
+        log.info("queue registered: ref = {}", queueRef);
 //        asyncService.registerQueue("update-queue", 1, updateArticeCallable);
 
         AsyncService.QueueRef queue = asyncService.getQueue("create-queue");
 
-        AsyncService.ExecutionRef executionRef = asyncService.schedule(queue);
+        List<AsyncService.ExecutionRef> refs = new ArrayList<>();
+
+        for (int i = 0; i < 10; i++) {
+            refs.add(asyncService.schedule(queue));
+        }
     }
 }