From 213f8956dce6a8f09709c00224fd8495ee30f423 Mon Sep 17 00:00:00 2001 From: runner Date: Thu, 24 Oct 2024 14:17:20 +0000 Subject: [PATCH] Publish guide for 2.0.3 --- index.html | 34 +++++++++++++++++++++++----------- 1 file changed, 23 insertions(+), 11 deletions(-) diff --git a/index.html b/index.html index 3237bacf..e4c5d89a 100644 --- a/index.html +++ b/index.html @@ -92,7 +92,7 @@

Micronaut Worker

Vladimir Orany
-version 2.0.2 +version 2.0.3
Table of Contents
@@ -201,22 +201,22 @@

2. Installa } dependencies { - implementation 'com.agorapulse:micronaut-worker:2.0.2' + implementation 'com.agorapulse:micronaut-worker:2.0.3' // to enable /jobs endpoint - implementation 'com.agorapulse:micronaut-worker-management:2.0.2' + implementation 'com.agorapulse:micronaut-worker-management:2.0.3' // to enable AWS SDK v1 SQS queues integration - implementation 'com.agorapulse:micronaut-worker-queues-sqs-v1:2.0.2' + implementation 'com.agorapulse:micronaut-worker-queues-sqs-v1:2.0.3' // to enable AWS SDK v2 SQS queues integration - implementation 'com.agorapulse:micronaut-worker-queues-sqs-v2:2.0.2' + implementation 'com.agorapulse:micronaut-worker-queues-sqs-v2:2.0.3' // to enable Redis leader/follower capabilities - implementation 'com.agorapulse:micronaut-worker-executor-redis:2.0.2' + implementation 'com.agorapulse:micronaut-worker-executor-redis:2.0.3' // to enable Redis queues integration - implementation 'com.agorapulse:micronaut-worker-queues-redis:2.0.2' + implementation 'com.agorapulse:micronaut-worker-queues-redis:2.0.3' // you also need Redis configuration on the classpath depending on your Micronaut version // for Micronaut 1.x @@ -447,11 +447,23 @@

Producer
Producer Job
@InitialDelay("50ms")
-public Flowable<String> hello() {
-    return Flowable.just("Hello", "World");
+public Flux<String> hello() {
+    return Flux.just("Hello", "World");
 }
+
+ + + + + +
+ + +If the producer job returns a Publisher, the messages can be batched if underlying implementation supports it. At the moment, only SQS AWS v2 implementation supports batching. +
+
Consumer
@@ -928,8 +940,8 @@

4. Links