Hello community,
here is the log from the commit of package rubygem-amq-protocol for
openSUSE:Factory checked in at 2020-05-11 13:38:56
++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
Comparing /work/SRC/openSUSE:Factory/rubygem-amq-protocol (Old)
and /work/SRC/openSUSE:Factory/.rubygem-amq-protocol.new.2738 (New)
++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
Package is "rubygem-amq-protocol"
Mon May 11 13:38:56 2020 rev:17 rq:802325 version:2.3.1
Changes:
--------
---
/work/SRC/openSUSE:Factory/rubygem-amq-protocol/rubygem-amq-protocol.changes
2018-01-17 21:59:23.624169549 +0100
+++
/work/SRC/openSUSE:Factory/.rubygem-amq-protocol.new.2738/rubygem-amq-protocol.changes
2020-05-11 13:39:00.496822573 +0200
@@ -1,0 +2,21 @@
+Thu May 7 20:06:07 UTC 2020 - Stephan Kulow <[email protected]>
+
+- updated to version 2.3.1
+ see installed ChangeLog.md
+
+ ## Changes between 2.3.1 and 2.3.2 (unreleased)
+
+ No changes yet.
+
+
+ ## Changes between 2.3.0 and 2.3.1 (April 8th, 2020)
+
+ ### Support for connection.update-secret
+
+ Used together with the `rabbitmq-auth-backend-oauth2` plugin.
+
+ ### Squashed a gemspec Warning
+
+ GitHub issue:
[ruby-amqp/amq-protocol#75](https://github.com/ruby-amqp/amq-protocol/issues/75).
+
+-------------------------------------------------------------------
Old:
----
amq-protocol-2.3.0.gem
New:
----
amq-protocol-2.3.1.gem
++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
Other differences:
------------------
++++++ rubygem-amq-protocol.spec ++++++
--- /var/tmp/diff_new_pack.0cVwba/_old 2020-05-11 13:39:01.316824292 +0200
+++ /var/tmp/diff_new_pack.0cVwba/_new 2020-05-11 13:39:01.320824300 +0200
@@ -1,7 +1,7 @@
#
# spec file for package rubygem-amq-protocol
#
-# Copyright (c) 2018 SUSE LINUX GmbH, Nuernberg, Germany.
+# Copyright (c) 2020 SUSE LLC
#
# All modifications and additions to the file contributed by third parties
# remain the property of their copyright owners, unless otherwise agreed
@@ -12,7 +12,7 @@
# license that conforms to the Open Source Definition (Version 1.9)
# published by the Open Source Initiative.
-# Please submit bugfixes or comments via http://bugs.opensuse.org/
+# Please submit bugfixes or comments via https://bugs.opensuse.org/
#
@@ -24,7 +24,7 @@
#
Name: rubygem-amq-protocol
-Version: 2.3.0
+Version: 2.3.1
Release: 0
%define mod_name amq-protocol
%define mod_full_name %{mod_name}-%{version}
@@ -38,7 +38,7 @@
BuildRequires: %{ruby >= 2.2}
BuildRequires: %{rubygem gem2rpm}
BuildRequires: ruby-macros >= 5
-Url: http://github.com/ruby-amqp/amq-protocol
+URL: http://github.com/ruby-amqp/amq-protocol
Source: https://rubygems.org/gems/%{mod_full_name}.gem
Source1: gem2rpm.yml
Summary: AMQP 0.9.1 encoding & decoding library
++++++ amq-protocol-2.3.0.gem -> amq-protocol-2.3.1.gem ++++++
diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn'
'--exclude=.svnignore' old/.travis.yml new/.travis.yml
--- old/.travis.yml 2018-01-08 13:15:06.000000000 +0100
+++ new/.travis.yml 2020-04-08 05:26:40.000000000 +0200
@@ -1,12 +1,14 @@
+dist: bionic
language: ruby
bundler_args: --without development
cache: bundler
script: "bundle exec rspec spec"
rvm:
- ruby-head
- - "2.4.1"
- - "2.3.4"
- - "2.2.7"
+ - "2.6.3"
+ - "2.5.5"
+ - "2.4.5"
+ - "2.3.8"
notifications:
recipients:
- [email protected]
diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn'
'--exclude=.svnignore' old/ChangeLog.md new/ChangeLog.md
--- old/ChangeLog.md 2018-01-08 13:15:06.000000000 +0100
+++ new/ChangeLog.md 2020-04-08 05:26:40.000000000 +0200
@@ -1,3 +1,20 @@
+## Changes between 2.3.1 and 2.3.2 (unreleased)
+
+No changes yet.
+
+
+## Changes between 2.3.0 and 2.3.1 (April 8th, 2020)
+
+### Support for connection.update-secret
+
+Used together with the `rabbitmq-auth-backend-oauth2` plugin.
+
+### Squashed a gemspec Warning
+
+GitHub issue:
[ruby-amqp/amq-protocol#75](https://github.com/ruby-amqp/amq-protocol/issues/75).
+
+
+
## Changes between 2.2.0 and 2.3.0 (Jan 8th, 2018)
### Support for Additional URI Query Parameters
diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn'
'--exclude=.svnignore' old/Gemfile new/Gemfile
--- old/Gemfile 2018-01-08 13:15:06.000000000 +0100
+++ new/Gemfile 2020-04-08 05:26:40.000000000 +0200
@@ -10,9 +10,8 @@
end
group :test do
- gem "rspec", ">= 3.5.0"
+ gem "rspec", ">= 3.8.0"
gem "rspec-its"
- gem "effin_utf8"
gem "simplecov"
end
diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn'
'--exclude=.svnignore' old/README.md new/README.md
--- old/README.md 2018-01-08 13:15:06.000000000 +0100
+++ new/README.md 2020-04-08 05:26:40.000000000 +0200
@@ -1,16 +1,17 @@
-# What is amq-protocol.
+# What is amq-protocol
amq-protocol is an AMQP 0.9.1 serialization library for Ruby. It is not an
-AMQP client: amq-protocol only handles serialization and deserialization.
+AMQP 0-9-1 client such as [Bunny](http://rubybunny.info): amq-protocol only
handles serialization and deserialization.
-If you want to write your own AMQP client, this gem will handle all the
serialization
+If you want to write your own AMQP 0-9-1 client, this gem will handle all the
serialization
needs for you, including RabbitMQ extensions to AMQP 0.9.1.
## Supported Ruby Versions
-amq-protocol `1.9.2` was the last version to support Ruby 1.8 and 1.9.
-amq-protocol `2.0.0` and later only supports Ruby 2.0+.
+ * amq-protocol `2.3.0` only supports Ruby 2.2+.
+ * amq-protocol `2.0.0` through `2.2.0` and later supports Ruby 2.0+.
+ * amq-protocol `1.9.2` was the last version to support Ruby 1.8 and 1.9.
## Installation
@@ -46,7 +47,7 @@
## CI Status
-[](https://travis-ci.org/ruby-amqp/amq-protocol)
+[](https://travis-ci.org/ruby-amqp/amq-protocol)
## Issues
diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn'
'--exclude=.svnignore' old/amq-protocol.gemspec new/amq-protocol.gemspec
--- old/amq-protocol.gemspec 2018-01-08 13:15:06.000000000 +0100
+++ new/amq-protocol.gemspec 2020-04-08 05:26:40.000000000 +0200
@@ -24,6 +24,4 @@
s.require_paths = ["lib"]
s.extra_rdoc_files = ["README.md"] + Dir.glob("doc/*")
-
- s.rubyforge_project = "amq-protocol"
end
Binary files old/checksums.yaml.gz and new/checksums.yaml.gz differ
diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn'
'--exclude=.svnignore' old/lib/amq/protocol/client.rb
new/lib/amq/protocol/client.rb
--- old/lib/amq/protocol/client.rb 2018-01-08 13:15:06.000000000 +0100
+++ new/lib/amq/protocol/client.rb 2020-04-08 05:26:40.000000000 +0200
@@ -251,7 +251,7 @@
end
# @return
- # ['client_properties = nil', "mechanism = 'PLAIN'", 'response = nil',
"locale = 'en_US'"]
+ # [u'client_properties = nil', u"mechanism = u'PLAIN'", u'response =
nil', u"locale = u'en_US'"]
def self.encode(client_properties, mechanism, response, locale)
channel = 0
buffer = @packed_indexes.dup
@@ -307,7 +307,7 @@
end
# @return
- # ['response = nil']
+ # [u'response = nil']
def self.encode(response)
channel = 0
buffer = @packed_indexes.dup
@@ -362,7 +362,7 @@
end
# @return
- # ['channel_max = false', 'frame_max = false', 'heartbeat = false']
+ # [u'channel_max = false', u'frame_max = false', u'heartbeat = false']
def self.encode(channel_max, frame_max, heartbeat)
channel = 0
buffer = @packed_indexes.dup
@@ -386,7 +386,7 @@
end
# @return
- # ["virtual_host = '/'", 'capabilities = EMPTY_STRING', 'insist =
false']
+ # [u"virtual_host = u'/'", u'capabilities = EMPTY_STRING', u'insist =
false']
def self.encode(virtual_host)
capabilities = EMPTY_STRING
insist = false
@@ -467,7 +467,7 @@
end
# @return
- # ['reply_code = nil', 'reply_text = EMPTY_STRING', 'class_id = nil',
'method_id = nil']
+ # [u'reply_code = nil', u'reply_text = EMPTY_STRING', u'class_id =
nil', u'method_id = nil']
def self.encode(reply_code, reply_text, class_id, method_id)
channel = 0
buffer = @packed_indexes.dup
@@ -536,7 +536,7 @@
end
# @return
- # ['reason = EMPTY_STRING']
+ # [u'reason = EMPTY_STRING']
def self.encode(reason)
channel = 0
buffer = @packed_indexes.dup
@@ -576,6 +576,79 @@
end
+ class UpdateSecret < Protocol::Method
+ @name = "connection.update-secret"
+ @method_id = 70
+ @index = 0x000A0046 # 10, 70, 655430
+ @packed_indexes = [10, 70].pack(PACK_UINT16_X2).freeze
+
+ # @return
+ def self.decode(data)
+ offset = offset = 0 # self-assigning offset to eliminate "assigned
but unused variable" warning even if offset is not used in this method
+ length = data[offset, 4].unpack(PACK_UINT32).first
+ offset += 4
+ new_secret = data[offset, length]
+ offset += length
+ length = data[offset, 1].unpack(PACK_CHAR).first
+ offset += 1
+ reason = data[offset, length]
+ offset += length
+ self.new(new_secret, reason)
+ end
+
+ attr_reader :new_secret, :reason
+ def initialize(new_secret, reason)
+ @new_secret = new_secret
+ @reason = reason
+ end
+
+ def self.has_content?
+ false
+ end
+
+ # @return
+ # [u'new_secret = nil', u'reason = nil']
+ def self.encode(new_secret, reason)
+ channel = 0
+ buffer = @packed_indexes.dup
+ buffer << [new_secret.to_s.bytesize].pack(PACK_UINT32)
+ buffer << new_secret.to_s
+ buffer << reason.to_s.bytesize.chr
+ buffer << reason.to_s
+ MethodFrame.new(buffer, channel)
+ end
+
+ end
+
+ class UpdateSecretOk < Protocol::Method
+ @name = "connection.update-secret-ok"
+ @method_id = 71
+ @index = 0x000A0047 # 10, 71, 655431
+ @packed_indexes = [10, 71].pack(PACK_UINT16_X2).freeze
+
+ # @return
+ def self.decode(data)
+ offset = offset = 0 # self-assigning offset to eliminate "assigned
but unused variable" warning even if offset is not used in this method
+ self.new()
+ end
+
+ def initialize()
+ end
+
+ def self.has_content?
+ false
+ end
+
+ # @return
+ # []
+ def self.encode()
+ channel = 0
+ buffer = @packed_indexes.dup
+ MethodFrame.new(buffer, channel)
+ end
+
+ end
+
end
class Channel < Protocol::Class
@@ -596,7 +669,7 @@
end
# @return
- # ['out_of_band = EMPTY_STRING']
+ # [u'out_of_band = EMPTY_STRING']
def self.encode(channel, out_of_band)
buffer = @packed_indexes.dup
buffer << out_of_band.to_s.bytesize.chr
@@ -659,7 +732,7 @@
end
# @return
- # ['active = nil']
+ # [u'active = nil']
def self.encode(channel, active)
buffer = @packed_indexes.dup
bit_buffer = 0
@@ -695,7 +768,7 @@
end
# @return
- # ['active = nil']
+ # [u'active = nil']
def self.encode(channel, active)
buffer = @packed_indexes.dup
bit_buffer = 0
@@ -741,7 +814,7 @@
end
# @return
- # ['reply_code = nil', 'reply_text = EMPTY_STRING', 'class_id = nil',
'method_id = nil']
+ # [u'reply_code = nil', u'reply_text = EMPTY_STRING', u'class_id =
nil', u'method_id = nil']
def self.encode(channel, reply_code, reply_text, class_id, method_id)
buffer = @packed_indexes.dup
buffer << [reply_code].pack(PACK_UINT16)
@@ -802,7 +875,7 @@
end
# @return
- # ['ticket = 0', 'exchange = nil', "type = 'direct'", 'passive =
false', 'durable = false', 'auto_delete = false', 'internal = false', 'nowait =
false', 'arguments = {}']
+ # [u'ticket = 0', u'exchange = nil', u"type = u'direct'", u'passive =
false', u'durable = false', u'auto_delete = false', u'internal = false',
u'nowait = false', u'arguments = {}']
def self.encode(channel, exchange, type, passive, durable,
auto_delete, internal, nowait, arguments)
ticket = 0
buffer = @packed_indexes.dup
@@ -858,7 +931,7 @@
end
# @return
- # ['ticket = 0', 'exchange = nil', 'if_unused = false', 'nowait =
false']
+ # [u'ticket = 0', u'exchange = nil', u'if_unused = false', u'nowait =
false']
def self.encode(channel, exchange, if_unused, nowait)
ticket = 0
buffer = @packed_indexes.dup
@@ -908,7 +981,7 @@
end
# @return
- # ['ticket = 0', 'destination = nil', 'source = nil', 'routing_key =
EMPTY_STRING', 'nowait = false', 'arguments = {}']
+ # [u'ticket = 0', u'destination = nil', u'source = nil', u'routing_key
= EMPTY_STRING', u'nowait = false', u'arguments = {}']
def self.encode(channel, destination, source, routing_key, nowait,
arguments)
ticket = 0
buffer = @packed_indexes.dup
@@ -962,7 +1035,7 @@
end
# @return
- # ['ticket = 0', 'destination = nil', 'source = nil', 'routing_key =
EMPTY_STRING', 'nowait = false', 'arguments = {}']
+ # [u'ticket = 0', u'destination = nil', u'source = nil', u'routing_key
= EMPTY_STRING', u'nowait = false', u'arguments = {}']
def self.encode(channel, destination, source, routing_key, nowait,
arguments)
ticket = 0
buffer = @packed_indexes.dup
@@ -1024,7 +1097,7 @@
end
# @return
- # ['ticket = 0', 'queue = EMPTY_STRING', 'passive = false', 'durable =
false', 'exclusive = false', 'auto_delete = false', 'nowait = false',
'arguments = {}']
+ # [u'ticket = 0', u'queue = EMPTY_STRING', u'passive = false',
u'durable = false', u'exclusive = false', u'auto_delete = false', u'nowait =
false', u'arguments = {}']
def self.encode(channel, queue, passive, durable, exclusive,
auto_delete, nowait, arguments)
ticket = 0
buffer = @packed_indexes.dup
@@ -1090,7 +1163,7 @@
end
# @return
- # ['ticket = 0', 'queue = EMPTY_STRING', 'exchange = nil',
'routing_key = EMPTY_STRING', 'nowait = false', 'arguments = {}']
+ # [u'ticket = 0', u'queue = EMPTY_STRING', u'exchange = nil',
u'routing_key = EMPTY_STRING', u'nowait = false', u'arguments = {}']
def self.encode(channel, queue, exchange, routing_key, nowait,
arguments)
ticket = 0
buffer = @packed_indexes.dup
@@ -1144,7 +1217,7 @@
end
# @return
- # ['ticket = 0', 'queue = EMPTY_STRING', 'nowait = false']
+ # [u'ticket = 0', u'queue = EMPTY_STRING', u'nowait = false']
def self.encode(channel, queue, nowait)
ticket = 0
buffer = @packed_indexes.dup
@@ -1197,7 +1270,7 @@
end
# @return
- # ['ticket = 0', 'queue = EMPTY_STRING', 'if_unused = false',
'if_empty = false', 'nowait = false']
+ # [u'ticket = 0', u'queue = EMPTY_STRING', u'if_unused = false',
u'if_empty = false', u'nowait = false']
def self.encode(channel, queue, if_unused, if_empty, nowait)
ticket = 0
buffer = @packed_indexes.dup
@@ -1252,7 +1325,7 @@
end
# @return
- # ['ticket = 0', 'queue = EMPTY_STRING', 'exchange = nil',
'routing_key = EMPTY_STRING', 'arguments = {}']
+ # [u'ticket = 0', u'queue = EMPTY_STRING', u'exchange = nil',
u'routing_key = EMPTY_STRING', u'arguments = {}']
def self.encode(channel, queue, exchange, routing_key, arguments)
ticket = 0
buffer = @packed_indexes.dup
@@ -1540,7 +1613,7 @@
end
# @return
- # ['prefetch_size = false', 'prefetch_count = false', 'global = false']
+ # [u'prefetch_size = false', u'prefetch_count = false', u'global =
false']
def self.encode(channel, prefetch_size, prefetch_count, global)
buffer = @packed_indexes.dup
buffer << [prefetch_size].pack(PACK_UINT32)
@@ -1587,7 +1660,7 @@
end
# @return
- # ['ticket = 0', 'queue = EMPTY_STRING', 'consumer_tag =
EMPTY_STRING', 'no_local = false', 'no_ack = false', 'exclusive = false',
'nowait = false', 'arguments = {}']
+ # [u'ticket = 0', u'queue = EMPTY_STRING', u'consumer_tag =
EMPTY_STRING', u'no_local = false', u'no_ack = false', u'exclusive = false',
u'nowait = false', u'arguments = {}']
def self.encode(channel, queue, consumer_tag, no_local, no_ack,
exclusive, nowait, arguments)
ticket = 0
buffer = @packed_indexes.dup
@@ -1666,7 +1739,7 @@
end
# @return
- # ['consumer_tag = nil', 'nowait = false']
+ # [u'consumer_tag = nil', u'nowait = false']
def self.encode(channel, consumer_tag, nowait)
buffer = @packed_indexes.dup
buffer << consumer_tag.to_s.bytesize.chr
@@ -1719,7 +1792,7 @@
end
# @return
- # ['ticket = 0', 'exchange = EMPTY_STRING', 'routing_key =
EMPTY_STRING', 'mandatory = false', 'immediate = false', 'user_headers = nil',
'payload = ""', 'frame_size = nil']
+ # [u'ticket = 0', u'exchange = EMPTY_STRING', u'routing_key =
EMPTY_STRING', u'mandatory = false', u'immediate = false', 'user_headers =
nil', 'payload = ""', 'frame_size = nil']
def self.encode(channel, payload, user_headers, exchange, routing_key,
mandatory, immediate, frame_size)
ticket = 0
buffer = @packed_indexes.dup
@@ -1843,7 +1916,7 @@
end
# @return
- # ['ticket = 0', 'queue = EMPTY_STRING', 'no_ack = false']
+ # [u'ticket = 0', u'queue = EMPTY_STRING', u'no_ack = false']
def self.encode(channel, queue, no_ack)
ticket = 0
buffer = @packed_indexes.dup
@@ -1957,7 +2030,7 @@
end
# @return
- # ['delivery_tag = false', 'multiple = false']
+ # [u'delivery_tag = false', u'multiple = false']
def self.encode(channel, delivery_tag, multiple)
buffer = @packed_indexes.dup
buffer << AMQ::Pack.pack_uint64_big_endian(delivery_tag)
@@ -1981,7 +2054,7 @@
end
# @return
- # ['delivery_tag = nil', 'requeue = true']
+ # [u'delivery_tag = nil', u'requeue = true']
def self.encode(channel, delivery_tag, requeue)
buffer = @packed_indexes.dup
buffer << AMQ::Pack.pack_uint64_big_endian(delivery_tag)
@@ -2005,7 +2078,7 @@
end
# @return
- # ['requeue = false']
+ # [u'requeue = false']
def self.encode(channel, requeue)
buffer = @packed_indexes.dup
bit_buffer = 0
@@ -2028,7 +2101,7 @@
end
# @return
- # ['requeue = false']
+ # [u'requeue = false']
def self.encode(channel, requeue)
buffer = @packed_indexes.dup
bit_buffer = 0
@@ -2091,7 +2164,7 @@
end
# @return
- # ['delivery_tag = false', 'multiple = false', 'requeue = true']
+ # [u'delivery_tag = false', u'multiple = false', u'requeue = true']
def self.encode(channel, delivery_tag, multiple, requeue)
buffer = @packed_indexes.dup
buffer << AMQ::Pack.pack_uint64_big_endian(delivery_tag)
@@ -2271,7 +2344,7 @@
end
# @return
- # ['nowait = false']
+ # [u'nowait = false']
def self.encode(channel, nowait)
buffer = @packed_indexes.dup
bit_buffer = 0
diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn'
'--exclude=.svnignore' old/lib/amq/protocol/table_value_decoder.rb
new/lib/amq/protocol/table_value_decoder.rb
--- old/lib/amq/protocol/table_value_decoder.rb 2018-01-08 13:15:06.000000000
+0100
+++ new/lib/amq/protocol/table_value_decoder.rb 2020-04-08 05:26:40.000000000
+0200
@@ -125,7 +125,7 @@
def self.decode_big_decimal(data, offset)
decimals, raw = data.slice(offset, 5).unpack(PACK_UCHAR_UINT32)
offset += 5
- v = BigDecimal.new(raw.to_s) * (BigDecimal.new(TEN) ** -decimals)
+ v = BigDecimal(raw.to_s) * (BigDecimal(TEN) ** -decimals)
[v, offset]
end # self.decode_big_decimal(data, offset)
diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn'
'--exclude=.svnignore' old/lib/amq/protocol/version.rb
new/lib/amq/protocol/version.rb
--- old/lib/amq/protocol/version.rb 2018-01-08 13:15:06.000000000 +0100
+++ new/lib/amq/protocol/version.rb 2020-04-08 05:26:40.000000000 +0200
@@ -1,5 +1,5 @@
module AMQ
module Protocol
- VERSION = "2.3.0"
+ VERSION = "2.3.1"
end # Protocol
end # AMQ
diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn'
'--exclude=.svnignore' old/metadata new/metadata
--- old/metadata 2018-01-08 13:15:06.000000000 +0100
+++ new/metadata 2020-04-08 05:26:40.000000000 +0200
@@ -1,7 +1,7 @@
--- !ruby/object:Gem::Specification
name: amq-protocol
version: !ruby/object:Gem::Version
- version: 2.3.0
+ version: 2.3.1
platform: ruby
authors:
- Jakub Stastny
@@ -11,7 +11,7 @@
autorequire:
bindir: bin
cert_chain: []
-date: 2018-01-08 00:00:00.000000000 Z
+date: 2020-04-08 00:00:00.000000000 Z
dependencies: []
description: |2
amq-protocol is an AMQP 0.9.1 serialization library for Ruby. It is not a
@@ -101,8 +101,7 @@
- !ruby/object:Gem::Version
version: '0'
requirements: []
-rubyforge_project: amq-protocol
-rubygems_version: 2.6.13
+rubygems_version: 3.0.3
signing_key:
specification_version: 4
summary: AMQP 0.9.1 encoding & decoding library.
diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn'
'--exclude=.svnignore' old/spec/amq/protocol/table_spec.rb
new/spec/amq/protocol/table_spec.rb
--- old/spec/amq/protocol/table_spec.rb 2018-01-08 13:15:06.000000000 +0100
+++ new/spec/amq/protocol/table_spec.rb 2020-04-08 05:26:40.000000000 +0200
@@ -5,8 +5,8 @@
module Protocol
RSpec.describe Table do
timestamp = Time.utc(2010, 12, 31, 23, 58, 59)
- bigdecimal_1 = BigDecimal.new("1.0")
- bigdecimal_2 = BigDecimal.new("5E-3")
+ bigdecimal_1 = BigDecimal("1.0")
+ bigdecimal_2 = BigDecimal("5E-3")
DATA = {
{} => "\x00\x00\x00\x00",
diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn'
'--exclude=.svnignore' old/spec/amq/protocol/value_decoder_spec.rb
new/spec/amq/protocol/value_decoder_spec.rb
--- old/spec/amq/protocol/value_decoder_spec.rb 2018-01-08 13:15:06.000000000
+0100
+++ new/spec/amq/protocol/value_decoder_spec.rb 2020-04-08 05:26:40.000000000
+0200
@@ -8,7 +8,7 @@
it "is capable of decoding basic arrays TableValueEncoder encodes" do
input1 = [1, 2, 3]
- value, offset =
described_class.decode_array(TableValueEncoder.encode(input1), 1)
+ value, _offset =
described_class.decode_array(TableValueEncoder.encode(input1), 1)
expect(value.size).to eq(3)
expect(value.first).to eq(1)
expect(value).to eq(input1)
@@ -17,7 +17,7 @@
input2 = ["one", 2, "three"]
- value, offset =
described_class.decode_array(TableValueEncoder.encode(input2), 1)
+ value, _offset =
described_class.decode_array(TableValueEncoder.encode(input2), 1)
expect(value.size).to eq(3)
expect(value.first).to eq("one")
expect(value).to eq(input2)
@@ -26,7 +26,7 @@
input3 = ["one", 2, "three", 4.0, 5000000.0]
- value, offset =
described_class.decode_array(TableValueEncoder.encode(input3), 1)
+ value, _offset =
described_class.decode_array(TableValueEncoder.encode(input3), 1)
expect(value.size).to eq(5)
expect(value.last).to eq(5000000.0)
expect(value).to eq(input3)
@@ -42,7 +42,7 @@
# puts(TableValueEncoder.encode(input1).inspect)
- value, offset = described_class.decode_array(data1, 1)
+ value, _offset = described_class.decode_array(data1, 1)
expect(value.size).to eq(2)
expect(value.first).to eq(Hash["one" => 2])
expect(value).to eq(input1)
@@ -51,7 +51,7 @@
input2 = ["one", 2, { "three" => { "four" => 5.0 } }]
- value, offset =
described_class.decode_array(TableValueEncoder.encode(input2), 1)
+ value, _offset =
described_class.decode_array(TableValueEncoder.encode(input2), 1)
expect(value.size).to eq(3)
expect(value.last["three"]["four"]).to eq(5.0)
expect(value).to eq(input2)
