there are only active channels, none for reuse

cloudamqp · May 9, 2024 · 7fdb094 · 7fdb094
1 parent 749dd6d
commit 7fdb094
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 5 deletions.
diff --git a/src/amqproxy/channel_pool.cr b/src/amqproxy/channel_pool.cr
@@ -70,7 +70,7 @@ module AMQProxy
         @lock.synchronize do
           (@upstreams.size - 1).times do # leave at least one connection
             u = @upstreams.pop
-            if u.active_channels.zero?
+            if u.channels.zero?
               begin
                 u.close "Pooled connection closed due to inactivity"
               rescue ex

diff --git a/src/amqproxy/upstream.cr b/src/amqproxy/upstream.cr
@@ -59,10 +59,6 @@ module AMQProxy
       @channels.size
     end
 
-    def active_channels
-      @channels.size
-    end
-
     # Frames from upstream (to client)
     def read_loop(socket = @socket) # ameba:disable Metrics/CyclomaticComplexity
       Log.context.set(remote_address: @remote_address)