2.6.0

Author: michaelklishin

AGENTS.md

@@ -14,6 +14,30 @@ This library targets Ruby 3.0 and later versions.
 
  * Only add very important comments, both in tests and in the implementation
 
+## Change Log
+
+If asked to perform change log updates, consult and modify `ChangeLog.md` and stick to its
+existing writing style.
+
+
+## Releases
+
+### How to Roll (Produce) a New Release
+
+Suppose the current development version in `ChangeLog.md` has
+a `## Changes between X.Y.0 and X.(Y+1).0 (unreleased)` section at the top.
+
+To produce a new release:
+
+ 1. Update `ChangeLog.md`: replace `(unreleased)` with today's date, e.g. `(Mar 30, 2026)`. Make sure all notable changes since the previous release are listed
+ 2. Update the version in `lib/amq/protocol/version.rb` to match
+ 3. Commit with the message `X.(Y+1).0` (just the version number, nothing else)
+ 4. Tag the commit: `git tag vX.(Y+1).0`
+ 5. Bump the dev version: add a new `## Changes between X.(Y+1).0 and X.(Y+2).0 (unreleased)` section to `ChangeLog.md` with `No changes yet.` underneath, and update `lib/amq/protocol/version.rb` to the next dev version
+ 6. Commit with the message `Bump dev version`
+ 7. Push: `git push && git push --tags`
+
+
 ## Git Instructions
 
  * Never add yourself to the list of commit co-authors

ChangeLog.md

@@ -1,8 +1,20 @@
-## Changes between 2.5.1 and 2.6.0 (in development)
+## Changes between 2.6.0 and 2.7.0 (unreleased)
 
 No changes yet.
 
 
+## Changes between 2.5.1 and 2.6.0 (Mar 30, 2026)
+
+### Channel.Close Predicate Methods
+
+`Channel::Close` now provides predicate methods for identifying common
+channel closure reasons by reply code and text:
+
+ * `#delivery_ack_timeout?`: consumer [delivery acknowledgement timeout](https://www.rabbitmq.com/docs/consumers#acknowledgement-timeout)
+ * `#unknown_delivery_tag?`: unknown delivery tag (e.g. [double ack](https://www.rabbitmq.com/docs/channels#error-handling))
+ * `#message_too_large?`: message exceeded the configured max size
+
+
 ## Changes between 2.5.0 and 2.5.1 (Jan 19, 2026)
 
 ### Windows Installation Fixes

lib/amq/protocol.rb

@@ -2,3 +2,4 @@
 
 require "amq/protocol/version"
 require "amq/protocol/client"
+require "amq/protocol/channel_close"

lib/amq/protocol/channel_close.rb

@@ -0,0 +1,24 @@
+# frozen_string_literal: true
+
+module AMQ
+  module Protocol
+    class Channel
+      class Close
+        # @return [Boolean] true if the channel was closed due to a consumer delivery acknowledgement timeout
+        def delivery_ack_timeout?
+          reply_code == 406 && reply_text =~ /delivery acknowledgement on channel \d+ timed out/
+        end
+
+        # @return [Boolean] true if the channel was closed due to an unknown delivery tag (e.g. double ack)
+        def unknown_delivery_tag?
+          reply_code == 406 && reply_text =~ /unknown delivery tag/
+        end
+
+        # @return [Boolean] true if the channel was closed because a message exceeded the configured max size
+        def message_too_large?
+          reply_code == 406 && reply_text =~ /larger than configured max size/
+        end
+      end
+    end
+  end
+end

spec/amq/protocol/channel_close_spec.rb

@@ -0,0 +1,50 @@
+# encoding: binary
+
+module AMQ
+  module Protocol
+    class Channel
+      RSpec.describe Close do
+        describe "#delivery_ack_timeout?" do
+          it "returns true for delivery acknowledgement timeout" do
+            close = Close.new(406, "PRECONDITION_FAILED - delivery acknowledgement on channel 1 timed out. Timeout value used: 1800000 ms", 0, 0)
+            expect(close.delivery_ack_timeout?).to be_truthy
+          end
+
+          it "returns false for an unknown delivery tag" do
+            close = Close.new(406, "PRECONDITION_FAILED - unknown delivery tag 82", 0, 0)
+            expect(close.delivery_ack_timeout?).to be_falsey
+          end
+
+          it "returns false for a different reply code" do
+            close = Close.new(404, "NOT_FOUND - no queue", 0, 0)
+            expect(close.delivery_ack_timeout?).to be_falsey
+          end
+        end
+
+        describe "#unknown_delivery_tag?" do
+          it "returns true for an unknown delivery tag" do
+            close = Close.new(406, "PRECONDITION_FAILED - unknown delivery tag 82", 0, 0)
+            expect(close.unknown_delivery_tag?).to be_truthy
+          end
+
+          it "returns false for a delivery ack timeout" do
+            close = Close.new(406, "PRECONDITION_FAILED - delivery acknowledgement on channel 1 timed out. Timeout value used: 1800000 ms", 0, 0)
+            expect(close.unknown_delivery_tag?).to be_falsey
+          end
+        end
+
+        describe "#message_too_large?" do
+          it "returns true when message exceeds configured max size" do
+            close = Close.new(406, "PRECONDITION_FAILED - message size 2000000 is larger than configured max size 1000000", 0, 0)
+            expect(close.message_too_large?).to be_truthy
+          end
+
+          it "returns false for an unknown delivery tag" do
+            close = Close.new(406, "PRECONDITION_FAILED - unknown delivery tag 82", 0, 0)
+            expect(close.message_too_large?).to be_falsey
+          end
+        end
+      end
+    end
+  end
+end