remove non needed public getClient

smallrye · Mar 4, 2023 · e4659ed · e4659ed
1 parent fd4d19d
commit e4659ed
Showing 1 changed file with 1 addition and 5 deletions.
diff --git a/...ing-rabbitmq/src/main/java/io/smallrye/reactive/messaging/rabbitmq/RabbitMQConnector.java b/...ing-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);
         });