package io.trygvis.test; import io.trygvis.queue.Task; import io.trygvis.queue.TaskEffect; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.stereotype.Component; import java.util.Date; import java.util.List; import java.util.Random; import static java.util.Collections.emptyList; @Component("updateArticle") public class UpdateArticleCallable implements TaskEffect { private final Logger log = LoggerFactory.getLogger(getClass()); private final Random r = new Random(); @Override public List apply(Task task) throws Exception { List arguments = task.arguments; log.info("UpdateArticeJob.run: BEGIN"); Date now = new Date(); log.info("now = {}", now); /* TypedQuery
q = entityManager.createQuery(entityManager.getCriteriaBuilder().createQuery(Article.class)); List
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"); return emptyList(); } }