From a03d5154456587fc7920e632f083cc5f1e4318a9 Mon Sep 17 00:00:00 2001
From: Trygve Laugstøl <trygvis@inamo.no>
Date: Sat, 20 Apr 2013 17:29:18 +0200
Subject: wip

---
 src/main/java/io/trygvis/Main.java | 219 +++++++++++++++++++------------------
 1 file changed, 111 insertions(+), 108 deletions(-)

(limited to 'src/main/java/io/trygvis/Main.java')

diff --git a/src/main/java/io/trygvis/Main.java b/src/main/java/io/trygvis/Main.java
index f2f540f..f1bba26 100755
--- a/src/main/java/io/trygvis/Main.java
+++ b/src/main/java/io/trygvis/Main.java
@@ -1,108 +1,111 @@
-package io.trygvis;
-
-import io.trygvis.queue.*;
-import io.trygvis.queue.Queue;
-import org.hibernate.dialect.*;
-import org.slf4j.*;
-import org.slf4j.bridge.*;
-import org.springframework.beans.factory.annotation.*;
-import org.springframework.context.support.*;
-import org.springframework.stereotype.*;
-import org.springframework.transaction.*;
-import org.springframework.transaction.support.*;
-
-import java.util.*;
-
-import static java.lang.System.*;
-import static java.lang.Thread.*;
-import static org.springframework.transaction.TransactionDefinition.PROPAGATION_REQUIRED;
-
-@Component
-public class Main {
-    private static final Logger log = LoggerFactory.getLogger(Main.class);
-
-    public static void main(String[] args) throws Exception {
-        SLF4JBridgeHandler.install();
-
-        String username = getProperty("user.name");
-        setProperty("database.url", getProperty("jdbc.url", "jdbc:postgresql://localhost/" + username));
-        setProperty("database.username", username);
-        setProperty("database.password", username);
-//        setProperty("hibernate.showSql", "true");
-        setProperty("hibernate.hbm2ddl.auto", "create"); // create
-        setProperty("hibernate.dialect", PostgreSQL82Dialect.class.getName());
-
-        log.info("Starting context");
-        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("applicationContext.xml");
-        log.info("Started context");
-
-        try {
-            context.getBean(Main.class).run();
-            log.info("Sleeping");
-            sleep(1000 * 1000);
-        } catch (Exception e) {
-            e.printStackTrace(System.out);
-        }
-
-        log.info("Stopping context");
-        context.stop();
-        log.info("Stopped context");
-
-        exit(0);
-    }
-
-    @Autowired
-    private TransactionTemplate transactionTemplate;
-
-    @Autowired
-    private AsyncService asyncService;
-
-    @Autowired
-    @Qualifier("createArticle")
-    private AsyncService.AsyncCallable createArticleCallable;
-
-    @Autowired
-    @Qualifier("createArticle")
-    private AsyncService.AsyncCallable/*UpdateArticleCallable*/ updateArticleCallable;
-
-    public void run() throws Exception {
-        log.info("Main.run");
-
-        final Queue q = asyncService.registerQueue("create-queue", 10, createArticleCallable);
-//        log.info("queue registered: ref = {}", q);
-//        asyncService.registerQueue("update-queue", 1, updateArticeCallable);
-
-//        q = asyncService.getQueue("create-queue");
-
-        final List<Task> tasks = new ArrayList<>();
-
-        transactionTemplate.execute(new TransactionCallbackWithoutResult() {
-            protected void doInTransactionWithoutResult(TransactionStatus status) {
-                for (int i = 0; i < 1; i++) {
-                    tasks.add(asyncService.schedule(q));
-                }
-            }
-        });
-
-        while (true) {
-            sleep(10000);
-
-            log.info("tasks.size = {}", tasks.size());
-            for (Iterator<Task> iterator = tasks.iterator(); iterator.hasNext(); ) {
-                Task task = iterator.next();
-
-                task = asyncService.update(task);
-
-                log.info("task = {}", task);
-
-                if (task.isDone()) {
-                    iterator.remove();
-                }
-            }
-
-            if (tasks.isEmpty()) {
-                break;
-            }
-        }
-    }
-}
+package io.trygvis;
+
+import io.trygvis.queue.*;
+import io.trygvis.queue.Queue;
+import org.hibernate.dialect.*;
+import org.slf4j.*;
+import org.slf4j.bridge.*;
+import org.springframework.beans.factory.annotation.*;
+import org.springframework.context.support.*;
+import org.springframework.stereotype.*;
+import org.springframework.transaction.*;
+import org.springframework.transaction.support.*;
+
+import java.util.*;
+
+import static java.lang.System.*;
+import static java.lang.Thread.*;
+
+@Component
+public class Main {
+    private static final Logger log = LoggerFactory.getLogger(Main.class);
+
+    public static void main(String[] args) throws Exception {
+        SLF4JBridgeHandler.install();
+
+        String username = getProperty("user.name");
+        setProperty("database.url", getProperty("jdbc.url", "jdbc:postgresql://localhost/" + username));
+        setProperty("database.username", username);
+        setProperty("database.password", username);
+//        setProperty("hibernate.showSql", "true");
+        setProperty("hibernate.hbm2ddl.auto", "create"); // create
+        setProperty("hibernate.dialect", PostgreSQL82Dialect.class.getName());
+
+        log.info("Starting context");
+        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("applicationContext.xml");
+        log.info("Started context");
+
+        try {
+            context.getBean(Main.class).run();
+//            log.info("Sleeping");
+//            sleep(1000 * 1000);
+        } catch (Exception e) {
+            e.printStackTrace(System.out);
+        }
+
+        log.info("Stopping context");
+        context.stop();
+        log.info("Stopped context");
+
+        exit(0);
+    }
+
+    @Autowired
+    private TransactionTemplate transactionTemplate;
+
+    @Autowired
+    private AsyncService asyncService;
+
+    @Autowired
+    @Qualifier("createArticle")
+    private AsyncService.AsyncCallable createArticleCallable;
+
+    @Autowired
+    @Qualifier("updateArticle")
+    private AsyncService.AsyncCallable updateArticleCallable;
+
+    public void run() throws Exception {
+        log.info("Main.run");
+
+        final Queue q = asyncService.registerQueue("create-article", 1, createArticleCallable);
+//        log.info("queue registered: ref = {}", q);
+//        asyncService.registerQueue("update-queue", 1, updateArticleCallable);
+
+//        q = asyncService.getQueue("create-queue");
+
+        final List<Task> tasks = new ArrayList<>();
+
+        final int count = 1;
+        log.info("Creating {} tasks", count);
+        transactionTemplate.execute(new TransactionCallbackWithoutResult() {
+            protected void doInTransactionWithoutResult(TransactionStatus status) {
+                for (int i = 0; i < count; i++) {
+                    tasks.add(asyncService.schedule(q));
+                }
+            }
+        });
+        log.info("Created {} tasks", count);
+
+        while (true) {
+            sleep(10000);
+
+            log.info("Checking for status of {} tasks", tasks.size());
+            for (Iterator<Task> iterator = tasks.iterator(); iterator.hasNext(); ) {
+                Task task = iterator.next();
+
+                task = asyncService.update(task);
+
+//                log.info("task = {}", task);
+
+                if (task.isDone()) {
+                    iterator.remove();
+                }
+            }
+
+            if (tasks.isEmpty()) {
+                log.info("No more tasks");
+                break;
+            }
+        }
+    }
+}
-- 
cgit v1.2.3