From e4659edfd2beaa3e8109f1c9774c68978bff4d9b Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?S=C3=A9bastien=20Crocquesel?=
 <88554524+scrocquesel@users.noreply.github.com>
Date: Sat, 4 Mar 2023 13:29:42 +0100
Subject: [PATCH] remove non needed public getClient

---
 .../reactive/messaging/rabbitmq/RabbitMQConnector.java      | 6 +-----
 1 file changed, 1 insertion(+), 5 deletions(-)

diff --git a/smallrye-reactive-messaging-rabbitmq/src/main/java/io/smallrye/reactive/messaging/rabbitmq/RabbitMQConnector.java b/smallrye-reactive-messaging-rabbitmq/src/main/java/io/smallrye/reactive/messaging/rabbitmq/RabbitMQConnector.java
index 48aa674dae..e6d3c3549f 100644
--- a/smallrye-reactive-messaging-rabbitmq/src/main/java/io/smallrye/reactive/messaging/rabbitmq/RabbitMQConnector.java
+++ b/smallrye-reactive-messaging-rabbitmq/src/main/java/io/smallrye/reactive/messaging/rabbitmq/RabbitMQConnector.java
@@ -459,12 +459,8 @@ public void addClient(String channel, RabbitMQClient client) {
         clients.put(channel, client);
     }
 
-    public RabbitMQClient getClient(String channel) {
-        return clients.get(channel);
-    }
-
     public void establishQueue(String channel, RabbitMQConnectorIncomingConfiguration ic) {
-        final RabbitMQClient client = getClient(channel);
+        final RabbitMQClient client = clients.get(channel);
         client.getDelegate().addConnectionEstablishedCallback(promise -> {
             establishQueue(client, ic).subscribe().with((ignored) -> promise.complete(), promise::fail);
         });