From 58e962a55b535213e7c7a74590c4028569c7ce42 Mon Sep 17 00:00:00 2001
From: Julien Ponge <jponge@redhat.com>
Date: Mon, 18 Mar 2024 15:18:53 +0100
Subject: [PATCH] Upgrade to Mutiny 2.6.0 with JCTools

---
 pom.xml                                                     | 6 +++---
 .../messaging/providers/extension/MediatorManager.java      | 6 +++---
 2 files changed, 6 insertions(+), 6 deletions(-)

diff --git a/pom.xml b/pom.xml
index 71425b6d7a..757b8758ff 100644
--- a/pom.xml
+++ b/pom.xml
@@ -82,7 +82,7 @@
 
     <micrometer.version>1.12.4</micrometer.version>
 
-    <mutiny.version>2.5.5</mutiny.version>
+    <mutiny.version>2.6.0</mutiny.version>
     <artemis.version>2.32.0</artemis.version>
     <commons-io.version>2.15.1</commons-io.version>
 
@@ -93,9 +93,9 @@
     <opentelemetry.version>1.31.0-alpha</opentelemetry.version>
     <opentelemetry-semconv.version>1.21.0-alpha</opentelemetry-semconv.version>
 
-    <smallrye-vertx-mutiny-clients.version>3.8.0</smallrye-vertx-mutiny-clients.version>
+    <smallrye-vertx-mutiny-clients.version>3.12.0</smallrye-vertx-mutiny-clients.version>
     <smallrye-reactive-converters.version>3.0.0</smallrye-reactive-converters.version>
-    <mutiny-zero.version>1.0.0</mutiny-zero.version>
+    <mutiny-zero.version>1.1.0</mutiny-zero.version>
 
     <testcontainers.version>1.19.7</testcontainers.version>
 
diff --git a/smallrye-reactive-messaging-provider/src/main/java/io/smallrye/reactive/messaging/providers/extension/MediatorManager.java b/smallrye-reactive-messaging-provider/src/main/java/io/smallrye/reactive/messaging/providers/extension/MediatorManager.java
index b7d3293c1f..2d8858c18c 100644
--- a/smallrye-reactive-messaging-provider/src/main/java/io/smallrye/reactive/messaging/providers/extension/MediatorManager.java
+++ b/smallrye-reactive-messaging-provider/src/main/java/io/smallrye/reactive/messaging/providers/extension/MediatorManager.java
@@ -18,7 +18,7 @@
 import org.eclipse.microprofile.reactive.messaging.Incoming;
 import org.eclipse.microprofile.reactive.messaging.Outgoing;
 
-import io.smallrye.mutiny.helpers.queues.Queues;
+import io.smallrye.mutiny.infrastructure.Infrastructure;
 import io.smallrye.reactive.messaging.*;
 import io.smallrye.reactive.messaging.EmitterConfiguration;
 import io.smallrye.reactive.messaging.PublisherDecorator;
@@ -114,12 +114,12 @@ private int getWorkerMaxConcurrency(MediatorConfiguration configuration) {
         String poolName = configuration.getWorkerPoolName();
         // if the poll name is null we are on the default worker pool, set the default concurrent requests
         if (poolName == null) {
-            return Queues.BUFFER_S;
+            return Infrastructure.getBufferSizeS();
         }
         String concurrencyConfigKey = WORKER_CONFIG_PREFIX + "." + poolName + "." + WORKER_CONCURRENCY;
         Optional<Integer> concurrency = configInstance.get().getOptionalValue(concurrencyConfigKey, Integer.class);
         // Fallback to the default concurrent requests if setting is not found
-        return concurrency.orElse(Queues.BUFFER_S);
+        return concurrency.orElse(Infrastructure.getBufferSizeS());
     }
 
     public Map<String, Integer> getIncomingConcurrency(MediatorConfiguration configuration) {