1 files changed, 10 insertions, 3 deletions
diff --git a/src/main/java/io/trygvis/CreateArticleCallable.java b/src/main/java/io/trygvis/CreateArticleCallable.java
index e727b46..85734fc 100755
--- a/src/main/java/io/trygvis/CreateArticleCallable.java
+++ b/src/main/java/io/trygvis/CreateArticleCallable.java
@@ -6,21 +6,28 @@ import org.slf4j.*;
 import org.springframework.stereotype.*;
 import org.springframework.transaction.annotation.*;
 
-import java.util.*;
 import javax.persistence.*;
+import java.util.*;
 
 import static org.springframework.transaction.annotation.Propagation.*;
 
-@Component
+@Component("createArticle")
+@Transactional(propagation = MANDATORY)
 public class CreateArticleCallable implements AsyncService.AsyncCallable {
     private final Logger log = LoggerFactory.getLogger(getClass());
 
     @PersistenceContext
     private EntityManager entityManager;
 
-//    @Transactional(propagation = REQUIRES_NEW)
+    private Random random = new Random();
+
     public void run() throws Exception {
         log.info("CreateArticeJob.run: BEGIN");
+
+        if (random.nextBoolean()) {
+            throw new RuntimeException("failing create article");
+        }
+
         Date now = new Date();
 
         log.info("now = {}", now);