aboutsummaryrefslogtreecommitdiff
path: root/src/main/java/io/trygvis/UpdateArticeCallable.java
diff options
context:
space:
mode:
authorTrygve Laugstøl <trygvis@inamo.no>2013-04-14 18:04:50 +0200
committerTrygve Laugstøl <trygvis@inamo.no>2013-04-14 18:04:50 +0200
commit8477e8a888d584cf1352a4b69d7cefb2b7cd9ace (patch)
treea99e339e302c31ef33e55bf7de5ae3333df11a92 /src/main/java/io/trygvis/UpdateArticeCallable.java
parentb59f08bb5b08be7972086037ec54b23ea9fb49f8 (diff)
downloadquartz-based-queue-8477e8a888d584cf1352a4b69d7cefb2b7cd9ace.tar.gz
quartz-based-queue-8477e8a888d584cf1352a4b69d7cefb2b7cd9ace.tar.bz2
quartz-based-queue-8477e8a888d584cf1352a4b69d7cefb2b7cd9ace.tar.xz
quartz-based-queue-8477e8a888d584cf1352a4b69d7cefb2b7cd9ace.zip
o Dropping quartz, using straight executor service.
Diffstat (limited to 'src/main/java/io/trygvis/UpdateArticeCallable.java')
-rwxr-xr-xsrc/main/java/io/trygvis/UpdateArticeCallable.java43
1 files changed, 0 insertions, 43 deletions
diff --git a/src/main/java/io/trygvis/UpdateArticeCallable.java b/src/main/java/io/trygvis/UpdateArticeCallable.java
deleted file mode 100755
index d022655..0000000
--- a/src/main/java/io/trygvis/UpdateArticeCallable.java
+++ /dev/null
@@ -1,43 +0,0 @@
-package io.trygvis;
-
-import io.trygvis.model.*;
-import io.trygvis.queue.*;
-import org.slf4j.*;
-import org.springframework.stereotype.*;
-import org.springframework.transaction.annotation.*;
-
-import java.util.*;
-import javax.persistence.*;
-
-import static org.springframework.transaction.annotation.Propagation.*;
-
-@Component
-public class UpdateArticeCallable implements AsyncService.AsyncCallable {
- private final Logger log = LoggerFactory.getLogger(getClass());
-
- private final Random r = new Random();
-
- @PersistenceContext
- private EntityManager entityManager;
-
-// @Transactional(propagation = REQUIRES_NEW)
- public void run() throws Exception {
- log.info("UpdateArticeJob.run: BEGIN");
-
- Date now = new Date();
-
- log.info("now = {}", now);
-
- TypedQuery<Article> q = entityManager.createQuery(entityManager.getCriteriaBuilder().createQuery(Article.class));
-
- List<Article> list = q.getResultList();
- log.info("Got {} articles", list.size());
-
- Article a = list.get(r.nextInt(list.size()));
- a.setUpdated(new Date());
-
- entityManager.persist(a);
-
- log.info("UpdateArticeJob.run: END");
- }
-}