fixup! Channel pool

cloudamqp · Feb 17, 2024 · 4bb7f52 · 4bb7f52
1 parent c044a6f
commit 4bb7f52
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/src/amqproxy/client.cr b/src/amqproxy/client.cr
@@ -23,7 +23,7 @@ module AMQProxy
     end
 
     # frames from enduser
-    def read_loop(channel_pool, socket = @socket)
+    def read_loop(channel_pool, socket = @socket) # ameba:disable Metrics/CyclomaticComplexity
       loop do
         case frame = AMQ::Protocol::Frame.from_io(socket, IO::ByteFormat::NetworkEndian)
         when AMQ::Protocol::Frame::Heartbeat

diff --git a/src/amqproxy/upstream.cr b/src/amqproxy/upstream.cr
@@ -70,7 +70,7 @@ module AMQProxy
     end
 
     # Frames from upstream (to client)
-    private def read_loop(socket = @socket)
+    private def read_loop(socket = @socket) # ameba:disable Metrics/CyclomaticComplexity
       loop do
         case frame = AMQ::Protocol::Frame.from_io(socket, IO::ByteFormat::NetworkEndian)
         when AMQ::Protocol::Frame::Heartbeat then send frame