better doc

Author: sterlp

core/src/main/java/org/sterl/spring/persistent_tasks/history/HistoryService.java

@@ -9,6 +9,7 @@
 import org.springframework.data.domain.Pageable;
 import org.springframework.data.domain.Sort;
 import org.springframework.data.domain.Sort.Direction;
+import org.springframework.lang.Nullable;
 import org.sterl.spring.persistent_tasks.api.TriggerKey;
 import org.sterl.spring.persistent_tasks.history.model.TriggerHistoryDetailEntity;
 import org.sterl.spring.persistent_tasks.history.model.TriggerHistoryLastStateEntity;
@@ -86,8 +87,15 @@ public long countTriggers(TriggerKey key) {
         return triggerHistoryLastStateRepository.countByKey(key);
     }
 
+    /**
+     * Checks for the last known state in the history.
+     * 
+     * @param key the {@link TriggerKey}, can be partly <code>null</code>
+     * @param page page informations
+     * @return the found data, looking only the last states
+     */
     public Page<TriggerHistoryLastStateEntity> findTriggerState(
-            TriggerKey key, Pageable page) {
+            @Nullable TriggerKey key, Pageable page) {
 
         page = sortByIdIfNeeded(page);
         if (key == null) return triggerHistoryLastStateRepository.findAll(page);
@@ -100,7 +108,7 @@ public Page<TriggerHistoryLastStateEntity> findTriggerState(
                 key.getTaskName(),
                 page);
     }
-    
+
     private Pageable sortByIdIfNeeded(Pageable page) {
         if (page.getSort() == Sort.unsorted()) {
             return PageRequest.of(page.getPageNumber(), page.getPageSize(), 

core/src/main/java/org/sterl/spring/persistent_tasks/history/component/TriggerHistoryComponent.java

@@ -13,9 +13,11 @@
 import org.sterl.spring.persistent_tasks.trigger.model.TriggerEntity;
 
 import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
 
 @TransactionalCompontant
 @RequiredArgsConstructor
+@Slf4j
 public class TriggerHistoryComponent {
 
     private final TriggerHistoryLastStateRepository triggerHistoryLastStateRepository;
@@ -36,9 +38,12 @@ public void write(TriggerEntity e) {
         triggerHistoryDetailRepository.save(detail);
     }
 
-    @Transactional
+    @Transactional(timeout = 10)
     @EventListener
     public void onPersistentTaskEvent(TriggerLifeCycleEvent triggerLifeCycleEvent) {
+        log.debug("Received event={} for {} new status={}",
+                triggerLifeCycleEvent.getClass().getSimpleName(),
+                triggerLifeCycleEvent.key(), triggerLifeCycleEvent.status());
         write(triggerLifeCycleEvent.trigger());
     }
 }

core/src/main/java/org/sterl/spring/persistent_tasks/trigger/event/TriggerLifeCycleEvent.java

@@ -5,6 +5,7 @@
 import org.springframework.lang.NonNull;
 import org.springframework.lang.Nullable;
 import org.sterl.spring.persistent_tasks.api.TriggerKey;
+import org.sterl.spring.persistent_tasks.shared.model.TriggerStatus;
 import org.sterl.spring.persistent_tasks.trigger.model.TriggerEntity;
 
 /**
@@ -14,6 +15,9 @@ public interface TriggerLifeCycleEvent {
     default TriggerKey key() {
         return trigger().getKey();
     }
+    default TriggerStatus status() {
+        return trigger().getData().getStatus();
+    }
     @NonNull
     TriggerEntity trigger();
     @Nullable