diff --git a/src/lavinmq/amqp/client.cr b/src/lavinmq/amqp/client.cr index 64f0315ca..08c948256 100644 --- a/src/lavinmq/amqp/client.cr +++ b/src/lavinmq/amqp/client.cr @@ -32,11 +32,11 @@ module LavinMQ Log = ::Log.for "AMQP.client" def initialize(@socket : IO, - @connection_info : ConnectionInfo, - @vhost : VHost, - @user : User, - tune_ok, - start_ok) + @connection_info : ConnectionInfo, + @vhost : VHost, + @user : User, + tune_ok, + start_ok) @remote_address = @connection_info.src @local_address = @connection_info.dst @@ -244,11 +244,11 @@ module LavinMQ @log.trace { "Send BodyFrame (pos #{pos}, length #{length})" } {% end %} body = case msg - in BytesMessage - AMQP::Frame::BytesBody.new(frame.channel, length, msg.body[pos, length]) - in Message - AMQP::Frame::Body.new(frame.channel, length, msg.body_io) - end + in BytesMessage + AMQP::Frame::BytesBody.new(frame.channel, length, msg.body[pos, length]) + in Message + AMQP::Frame::Body.new(frame.channel, length, msg.body_io) + end socket.write_bytes body, ::IO::ByteFormat::NetworkEndian socket.flush if websocket @send_oct_count += 8_u64 + body.bytesize diff --git a/src/lavinmq/amqp/connection_factory.cr b/src/lavinmq/amqp/connection_factory.cr index 633d9e8bb..a81baa35f 100644 --- a/src/lavinmq/amqp/connection_factory.cr +++ b/src/lavinmq/amqp/connection_factory.cr @@ -102,7 +102,7 @@ module LavinMQ username, password = credentials(start_ok) user = users[username]? return user if user && user.password && user.password.not_nil!.verify(password) && - guest_only_loopback?(remote_address, user) + guest_only_loopback?(remote_address, user) if user.nil? Log.warn { "User \"#{username}\" not found" }