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