#115 - disable publishing for OutboxEventService actions

Otherwise an infinite loop arises
incodehq · Oct 14, 2019 · 3407d35 · 3407d35
1 parent 9214de0
commit 3407d35
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/...box/src/main/java/org/isisaddons/module/publishmq/dom/outbox/rest/OutboxEventService.java b/...box/src/main/java/org/isisaddons/module/publishmq/dom/outbox/rest/OutboxEventService.java
@@ -8,6 +8,7 @@
 import org.apache.isis.applib.annotation.Action;
 import org.apache.isis.applib.annotation.DomainService;
 import org.apache.isis.applib.annotation.NatureOfService;
+import org.apache.isis.applib.annotation.Publishing;
 import org.apache.isis.applib.annotation.SemanticsOf;
 import org.apache.isis.applib.services.registry.ServiceRegistry;
 import org.isisaddons.module.publishmq.dom.outbox.events.OutboxEvent;
@@ -29,15 +30,15 @@ public class OutboxEventService {
      *
      * @return
      */
-    @Action(semantics = SemanticsOf.SAFE)
+    @Action(semantics = SemanticsOf.SAFE, publishing = Publishing.DISABLED)
     public OutboxEvents pending() {
         final OutboxEvents outboxEvents = serviceRegistry.injectServicesInto(new OutboxEvents());
         final List<OutboxEvent> oldest = outboxEventRepository.findOldest();
         outboxEvents.getEvents().addAll(oldest);
         return outboxEvents;
     }
 
-    @Action(semantics = SemanticsOf.IDEMPOTENT)
+    @Action(semantics = SemanticsOf.IDEMPOTENT, publishing = Publishing.DISABLED)
     public void delete(final String transactionId, final int sequence) {
         outboxEventRepository.deleteByTransactionIdAndSequence(UUID.fromString(transactionId), sequence);
     }