close code have to be a UInt16

cloudamqp · May 10, 2024 · 9ecdca1 · 9ecdca1
1 parent bdd7f52
commit 9ecdca1
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/src/amqproxy/client.cr b/src/amqproxy/client.cr
@@ -60,7 +60,7 @@ module AMQProxy
               # Channel::Close is sent, waiting for CloseOk
             end
           rescue ex : Upstream::WriteError
-            close_channel(src_channel)
+            close_channel(src_channel, 500_u16, "UPSTREAM_ERROR")
           rescue KeyError
             close_connection(504_u16, "CHANNEL_ERROR - Channel #{frame.channel} not open", frame)
           end
@@ -126,7 +126,7 @@ module AMQProxy
       @channel_map[id] = nil
     end
 
-    private def close_all_upstream_channels(code = 500, reason = "CLIENT_DISCONNECTED")
+    private def close_all_upstream_channels(code = 500_u16, reason = "CLIENT_DISCONNECTED")
       @channel_map.each_value do |upstream_channel|
         upstream_channel.try &.close(code, reason)
       rescue Upstream::WriteError

diff --git a/src/amqproxy/upstream.cr b/src/amqproxy/upstream.cr
@@ -97,7 +97,7 @@ module AMQProxy
       @socket.closed?
     end
 
-    private def close_all_client_channels(code = 500, reason = "UPSTREAM_ERROR")
+    private def close_all_client_channels(code = 500_u16, reason = "UPSTREAM_ERROR")
       @channels_lock.synchronize do
         return if @channels.empty?
         Log.debug { "Upstream connection closed, closing #{@channels.size} client channels" }