Added Transactional annotation to ensure connection obtained from db …

…have autocommit false.
Hyperfoil · Sep 29, 2023 · a6069eb · a6069eb
1 parent e3569e7
commit a6069eb
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/horreum-backend/src/main/java/io/hyperfoil/tools/horreum/bus/MessageBus.java b/horreum-backend/src/main/java/io/hyperfoil/tools/horreum/bus/MessageBus.java
@@ -245,6 +245,7 @@ void removeIndex(String channel, int index) {
          every = "{horreum.messagebus.retry.check:5m}",
          delayed = "{horreum.messagebus.retry.delay:30s}",
          concurrentExecution = Scheduled.ConcurrentExecution.SKIP)
+   @Transactional
    public void retryFailedMessages() {
 
       try(ScrollableResults<ChannelMessage> results = (ScrollableResults<ChannelMessage>) em.createNativeQuery("SELECT channel, id, testid, flags, message FROM messagebus WHERE \"timestamp\" + make_interval(secs => ?1) <= now()")