wip

1 files changed, 5 insertions, 6 deletions

diff --git a/src/main/java/io/trygvis/CreateArticleCallable.java b/src/main/java/io/trygvis/CreateArticleCallable.java
index 85734fc..671f3dc 100755
--- a/src/main/java/io/trygvis/CreateArticleCallable.java
+++ b/src/main/java/io/trygvis/CreateArticleCallable.java
@@ -6,7 +6,6 @@ import org.slf4j.*;
 import org.springframework.stereotype.*;
 import org.springframework.transaction.annotation.*;
 
-import javax.persistence.*;
 import java.util.*;
 
 import static org.springframework.transaction.annotation.Propagation.*;
@@ -16,15 +15,15 @@ import static org.springframework.transaction.annotation.Propagation.*;
 public class CreateArticleCallable implements AsyncService.AsyncCallable {
     private final Logger log = LoggerFactory.getLogger(getClass());
 
-    @PersistenceContext
-    private EntityManager entityManager;
+//    @PersistenceContext
+//    private EntityManager entityManager;
 
     private Random random = new Random();
 
-    public void run() throws Exception {
+    public void run(List<String> arguments) throws Exception {
         log.info("CreateArticeJob.run: BEGIN");
 
-        if (random.nextBoolean()) {
+        if (random.nextInt() % 3 == 0) {
             throw new RuntimeException("failing create article");
         }
 
@@ -33,7 +32,7 @@ public class CreateArticleCallable implements AsyncService.AsyncCallable {
         log.info("now = {}", now);
 
         Article article = new Article(new Date(), null, "title", "body");
-        entityManager.persist(article);
+//        entityManager.persist(article);
 
         log.info("CreateArticeJob.run: END");
     }