lib/amqp/client/connection.rb in amqp-client-1.1.0 vs lib/amqp/client/connection.rb in amqp-client-1.1.1

- old
+ new

@@ -1,11 +1,11 @@ # frozen_string_literal: true require "socket" require "uri" require "openssl" -require_relative "./frames" +require_relative "./frame_bytes" require_relative "./channel" require_relative "./errors" module AMQP class Client @@ -348,10 +348,10 @@ end else raise Error::UnsupportedMethodFrame.new class_id, method_id end when 2 # header body_size = buf.unpack1("@4 Q>") - properties = Properties.decode(buf.byteslice(12, buf.bytesize - 12)) + properties = Properties.decode(buf, 12) @channels[channel_id].header_delivered body_size, properties when 3 # body @channels[channel_id].body_delivered buf else raise Error::UnsupportedFrameType, type end