From b59f08bb5b08be7972086037ec54b23ea9fb49f8 Mon Sep 17 00:00:00 2001 From: Trygve Laugstøl Date: Thu, 11 Apr 2013 19:12:27 +0200 Subject: wip --- src/main/java/io/trygvis/Main.java | 12 +++++++++--- 1 file changed, 9 insertions(+), 3 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 19167d7..aafb728 100755 --- a/src/main/java/io/trygvis/Main.java +++ b/src/main/java/io/trygvis/Main.java @@ -29,7 +29,6 @@ public class Main { log.info("Starting context"); ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("applicationContext.xml"); - context.start(); log.info("Started context"); try { @@ -50,12 +49,19 @@ public class Main { @Autowired private AsyncService asyncService; + @Autowired + private CreateArticleCallable createArticleCallable; + + @Autowired + private UpdateArticeCallable updateArticeCallable; + public void run() throws Exception { log.info("Main.run"); - asyncService.registerQueue("test-queue", 1, MyJob.class); + asyncService.registerQueue("create-queue", 1, createArticleCallable); +// asyncService.registerQueue("update-queue", 1, updateArticeCallable); - AsyncService.QueueRef queue = asyncService.getQueue("test-queue"); + AsyncService.QueueRef queue = asyncService.getQueue("create-queue"); AsyncService.ExecutionRef executionRef = asyncService.schedule(queue); } -- cgit v1.2.3