Debug job detail.

sonus21 · Dec 3, 2019 · 177593b · 177593b
1 parent b12f7b0
commit 177593b
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/.../src/test/java/com/github/sonus21/rqueue/spring/boot/application/app/MessageListener.java b/.../src/test/java/com/github/sonus21/rqueue/spring/boot/application/app/MessageListener.java
@@ -24,20 +24,23 @@
 import com.github.sonus21.rqueue.spring.boot.application.app.service.FailureManager;
 import lombok.NonNull;
 import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 import org.springframework.transaction.annotation.Transactional;
 
 @Component
 @RequiredArgsConstructor(onConstructor = @__(@Autowired))
 @Transactional
+@Slf4j
 public class MessageListener {
   @NonNull private ConsumedMessageService consumedMessageService;
   @NonNull private FailureManager failureManager;
 
   @RqueueListener("${job.queue.name}")
   public void onMessage(Job job) throws Exception {
     if (failureManager.shouldFail(job.getId())) {
+      log.debug("{}", job);
       throw new Exception("Failing job task to be retried");
     }
     consumedMessageService.save(job);