#115 - adds query defns for OutboxEvent entity

incodehq · Oct 1, 2019 · 0dccde8 · 0dccde8
1 parent 00d117c
commit 0dccde8
Showing 1 changed file with 14 additions and 0 deletions.
diff --git a/...mq/impl/jdo/src/main/java/org/isisaddons/module/publishmq/dom/jdo/events/OutboxEvent.java b/...mq/impl/jdo/src/main/java/org/isisaddons/module/publishmq/dom/jdo/events/OutboxEvent.java
@@ -7,6 +7,20 @@
 @javax.jdo.annotations.PersistenceCapable(
         schema = "isispublishmq",
         table="OutboxEvent")
+@javax.jdo.annotations.Queries( {
+        @javax.jdo.annotations.Query(
+                name="findByTransactionIdAndSequence", language="JDOQL",
+                value="SELECT "
+                        + "FROM org.isisaddons.module.publishmq.dom.jdo.events.OutboxEvent "
+                        + "WHERE transactionId == :transactionId "
+                        + "&&    sequence      == :sequence "),
+        @javax.jdo.annotations.Query(
+                name="findOldest", language="JDOQL",
+                value="SELECT "
+                        + "FROM org.isisaddons.module.publishmq.dom.jdo.events.OutboxEvent "
+                        + "ORDER BY timestamp ASC, transactionId ASC, sequence ASC "
+                        + "RANGE 0,30")
+})
 @DomainObject(
         editing = Editing.DISABLED,
         objectType = "isispublishmq.OutboxEvent"