From 443a925df384cbe0f51ad9f54683e651dc8106b3 Mon Sep 17 00:00:00 2001
From: Julien Ponge <jponge@redhat.com>
Date: Mon, 22 Jan 2024 14:46:50 +0100
Subject: [PATCH] Prepare for Mutiny queues refactor

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

diff --git a/pom.xml b/pom.xml
index 66ed1ceb31..9f92cc8078 100644
--- a/pom.xml
+++ b/pom.xml
@@ -82,7 +82,7 @@
 
     <micrometer.version>1.12.2</micrometer.version>
 
-    <mutiny.version>2.5.3</mutiny.version>
+    <mutiny.version>999-SNAPSHOT</mutiny.version>
     <artemis.version>2.31.2</artemis.version>
     <commons-io.version>2.15.1</commons-io.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) {