From 41b144a3b9652874460283b3e0c69de4a199315f Mon Sep 17 00:00:00 2001 From: Jesper Saastamoinen Date: Fri, 31 Oct 2025 11:52:52 +0100 Subject: [PATCH] Cleaned up cronjob --- .../rabbitmq/producer/UpdateAktorCronJob.java | 19 ------------------- 1 file changed, 19 deletions(-) diff --git a/rabbitmq-akka/src/main/java/se/saasta/rabbitmq/producer/UpdateAktorCronJob.java b/rabbitmq-akka/src/main/java/se/saasta/rabbitmq/producer/UpdateAktorCronJob.java index e57aa14..63d17b2 100644 --- a/rabbitmq-akka/src/main/java/se/saasta/rabbitmq/producer/UpdateAktorCronJob.java +++ b/rabbitmq-akka/src/main/java/se/saasta/rabbitmq/producer/UpdateAktorCronJob.java @@ -1,14 +1,12 @@ package se.saasta.rabbitmq.producer; import io.quarkus.scheduler.Scheduled; -import io.quarkus.scheduler.ScheduledExecution; import jakarta.enterprise.context.ApplicationScoped; import org.eclipse.microprofile.reactive.messaging.Channel; import org.eclipse.microprofile.reactive.messaging.Emitter; import se.saasta.rabbitmq.model.AkkaData; import java.util.UUID; -import java.util.concurrent.atomic.AtomicInteger; @ApplicationScoped public class UpdateAktorCronJob { @@ -16,23 +14,6 @@ public class UpdateAktorCronJob { @Channel("akka") Emitter emitter; - private AtomicInteger counter = new AtomicInteger(); - - public int get() { - return counter.get(); - } - - @Scheduled(every = "10s") - void increment() { - counter.incrementAndGet(); - } - - @Scheduled(cron = "0 15 10 * * ?") - void cronJob(ScheduledExecution execution) { - counter.incrementAndGet(); - System.out.println(execution.getScheduledFireTime()); - } - @Scheduled(cron = "{cron.expr}") void cronJobWithExpressionInConfig() { AkkaData akkaData = new AkkaData();