Yeahsper/rabbitmq-quarkus
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Cleaned up cronjob

Browse source
This commit is contained in:
Jesper Saastamoinen 2025-10-31 11:52:52 +01:00
parent 9b35054423
commit 41b144a3b9
1 changed files with 0 additions and 19 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

19
rabbitmq-akka/src/main/java/se/saasta/rabbitmq/producer/UpdateAktorCronJob.java
View file

@ -1,14 +1,12 @@
package se.saasta.rabbitmq.producer; package se.saasta.rabbitmq.producer;
import io.quarkus.scheduler.Scheduled; import io.quarkus.scheduler.Scheduled;
import io.quarkus.scheduler.ScheduledExecution;
import jakarta.enterprise.context.ApplicationScoped; import jakarta.enterprise.context.ApplicationScoped;
import org.eclipse.microprofile.reactive.messaging.Channel; import org.eclipse.microprofile.reactive.messaging.Channel;
import org.eclipse.microprofile.reactive.messaging.Emitter; import org.eclipse.microprofile.reactive.messaging.Emitter;
import se.saasta.rabbitmq.model.AkkaData; import se.saasta.rabbitmq.model.AkkaData;
import java.util.UUID; import java.util.UUID;
import java.util.concurrent.atomic.AtomicInteger;
@ApplicationScoped @ApplicationScoped
public class UpdateAktorCronJob { public class UpdateAktorCronJob {
@ -16,23 +14,6 @@ public class UpdateAktorCronJob {
@Channel("akka") @Channel("akka")
Emitter<AkkaData> emitter; Emitter<AkkaData> 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}") @Scheduled(cron = "{cron.expr}")
void cronJobWithExpressionInConfig() { void cronJobWithExpressionInConfig() {
AkkaData akkaData = new AkkaData(); AkkaData akkaData = new AkkaData();