[Unreleased]

[2.1.0] - 2026-06-23

  • Changed: Dropped support for Ruby 3.2 (now requires Ruby >= 3.3).
  • Fixed: A malformed frame end during the connection handshake (e.g. connecting to a non-AMQP service) now raises the intended Error::UnexpectedFrameEnd instead of a NameError from a mistyped constant, which previously surfaced as a confusing invalid handshake (uninitialized constant AMQP::Client::Error::UnexpectedFrameTypeEnd) message
  • Fixed: The handshake now buffers the full 7-byte frame header before parsing it. On JRuby the header could arrive split across reads, leaving frame_size nil and raising NoMethodError ("undefined method '+' for nil") instead of UnexpectedFrameEnd when connecting to a non-AMQP service
  • Fixed: Channel#wait_for_confirms no longer hangs when the broker closes the channel (e.g. a publish to a missing exchange) right before the publishing thread starts waiting. The closed-channel check now runs before the condition-variable wait, so the wakeup from #closed! can't be lost. This resolves a flaky ChannelClosed-expected timeout that surfaced on truffleruby, whose threads run truly in parallel.
  • Fixed: When the read loop exits on an abrupt socket close (no channel/connection close frame from the broker), open channels are now marked closed, so callers blocked in #wait_for_confirms or awaiting a broker reply raise ConnectionClosed instead of hanging forever.
  • Fixed: An ack/nack for a delivery tag the channel isn't tracking (a duplicate, out-of-order, or broker quirk) is now ignored instead of raising. The previous bare RuntimeError ran on the read loop thread, tearing down the connection — and, under the high-level supervisor, aborting the whole process.
  • Fixed: Consumer#cancel now closes the dedicated channel opened by subscribe, preventing a channel leak on long-lived connections that subscribe/cancel repeatedly (#81)
  • Fixed: Consumer threads no longer crash with ConnectionClosed/ChannelClosed when the connection or channel closes while a delivery is being processed (e.g. an ack/reject/publish racing a shutdown); the consumer now stops quietly. Previously surfaced as a flaky error on JRuby/TruffleRuby, whose threads run truly in parallel.
  • Added: logger: option on AMQP::Client.new that emits info/warn lifecycle messages for connect, reconnect, and disconnect in the supervised #start loop. The prefix uses ?name= from the URL when present.
  • Added: Every thread the library spawns (read_loop, heartbeat, consumer workers, on_return, supervisor, reconnect_setup) now gets a descriptive Thread#name. When the URL includes ?name=, that identifier is embedded in each thread's name too, matching the lifecycle log prefix.

[2.0.1] - 2025-11-18

  • Fixed: Ensure closing channels on basic get high level api (#73)
  • Improved: Clean up migration guide
  • Added: GitHub release notes for v2.0.0

[2.0.0] - 2025-10-27

  • BREAKING CHANGE: Refactored public API to use keyword arguments for improved clarity and consistency
    • All methods now use keyword arguments instead of positional arguments (e.g., publish(body, exchange:, routing_key:))
  • BREAKING CHANGE: Channel#basic_subscribe methods now return Connection::Channel::ConsumeOk for better consumer response handling
  • BREAKING CHANGE: Connection::Channel::QueueOk converted from Struct to Data class
  • BREAKING CHANGE: Direct exchange default name changed from empty string to "amq.direct" for API consistency
  • BREAKING CHANGE: Client exchange convenience methods renamed to $type_exchange, e.g. direct_exchange for improved clarity
  • BREAKING_CHANGE: Client#subscribe and Queue#subscribe now return a Consumer which can be cancelled.
  • Added: Queue#subscribe now handles ack and rejects automatically
  • Added: RPC API
  • Added: Support no_wait argument in #basic_consume
  • Added: Client#started? to check if start has already been called and made Clinet#start idempotent
  • Added: Automatic message encoding/serialization for high level API (built-in JSON, Marshal etc. via codec registry)
  • Added: Support for default content_type and content_encoding at class and instance level (automatically applied to published messages unless explicitly overridden)
  • Added: AMQP::Client.configure block pattern for unified class-level configuration
  • Added: Queue#get and Client#get methods for polling messages from queues as an alternative to subscribe
  • Added: passive parameter to queue declaration for checking queue existence without creating it
  • Added: exclusive parameter to queue method and subscribe
  • Added: Message#delivery_info struct for easier access to delivery metadata (exchange, routing_key, delivery_tag, redelivered, consumer_tag)
  • Changed: Disabled nagle's algorithm
  • Fixed: Running minitest with --verbose flag no longer causes TypeError
  • Fixed: Clinet#start is now thread-safe
  • Fixed: wait_for_confirms handles NACKs and actually returns the promised success bool

[1.2.1] - 2025-09-15

  • Added: Convenience methods for creating exchange types: fanout(), direct(), topic(), and headers()
  • Added: Support for binding with high level objects (Exchange and Queue objects can now be passed as binding sources)
  • Fixed: Bug where a client without any connection could not be closed properly

[1.2.0] - 2025-09-10

  • Fixed: Connection#channel wasn't thread-safe
  • Added: Support for heartbeats

[1.1.7] - 2024-05-12

  • Support for Connection.update-secret
  • Allow sub-second connect_timeout
  • Fixed: undefinied variable if message was returned and no on_return block was set

[1.1.6] - 2024-03-26

  • Fixed: Channel#wait_for_confirms now waits for all confirms, in a thread safe way
  • Changed: When server sends Connection.blocked the client isn't write blocked anymore, and can continue consume for instance. However, the on_blocked/unblocked callbacks should be used and manually stop publishing as the server otherwise will stop reading from the client socket.

[1.1.5] - 2024-03-15

  • Fixed: Correctly reference the UnexpectedFrameEnd exception

[1.1.4] - 2021-12-27

  • Fixed: Ruby 3.1.0 compability, StringIO have to be required manually

[1.1.3] - 2021-11-04

  • Fixed: Reraise SystemcallError in connect so that reconnect works
  • Fixed: Keepalive support in OS X
  • Added: Make keepalive settings configurable (eg. amqp://?keepalive=60:10:3)

[1.1.2] - 2021-10-15

  • Added: Support for JRuby and TruffleRuby

[1.1.1] - 2021-09-15

  • Added: Examples in the documentation
  • Added: Faster Properties and Table encoding and decoding

[1.1.0] - 2021-09-08

  • Fixed: Due to a race condition publishers could get stuck waiting for publish confirms
  • Change: Message, ReturnMessage and Properties are now classes and not structs (for performance reasons)
  • Added: Ruby 2.6 support
  • Added: RBS signatures in sig/amqp-client.rbs

[1.0.2] - 2021-09-07

  • Changed: Raise ConnectionClosed and ChannelClosed correctly (previous always ChannelClosed)
  • Fixed: Respect Connection#blocked sent by the broker, will block all writes/requests

[1.0.1] - 2021-09-06

  • The API is fully documented! https://cloudamqp.github.io/amqp-client.rb/
  • Fixed: Socket writing is now thread-safe
  • Change: Block while waiting for basic_cancel by default
  • Added: Can specify channel_max, heartbeat and frame_max as options to the Client/Connection
  • Added: Reuse channel 1 to declare high level queues/exchanges
  • Fixed: Only wait for exchange_delete confirmation if not no_wait is set
  • Fixed: Don't raise if Connection#close detects a closed socket (expected)

[1.0.0] - 2021-08-27

  • Verify TLS certificate matches hostname
  • TLS thread-safety
  • Assemble Messages in the (single threaded) read_loop thread
  • Give read_loop_thread higher priority so that channel errors crop up faster
  • One less Thread required per Consumer
  • Read exactly one frame at a time, not trying to split/assemble frames over socket reads
  • Heafty speedup for message assembling with StringIO
  • Channel#queue_declare returns a struct for nicer API (still backward compatible)
  • AMQP::Client#publish_and_forget for fast, non confirmed publishes
  • Allow Properties#timestamp to be an integer (in addition to Time)
  • Bug fix allow Properties#expiration to be an Integer
  • Consistent use of named parameters
  • High level Exchange API
  • Don't try to reconnect if first connect fails
  • Bug fix: Close all channels when connection is closed by server
  • Raise error if run out of channels
  • Improved retry in high level client
  • Bug fix: Support channel_max 0

[0.3.0] - 2021-08-20

  • Channel#wait_for_confirms is a smarter way of waiting for publish confirms
  • Default connection_name to $PROGRAM_NAME

[0.2.3] - 2021-08-19

  • Improved TLS/AMQPS support

[0.2.2] - 2021-08-19

  • TLS port issue fixed

[0.2.1] - 2021-08-19

  • More arguments to be passed to AMQP::Client::Queue
  • Can require with 'amqp-client'

[0.2.0] - 2021-08-19

  • Much improved and with a high level client

[0.1.0] - 2021-04-13

  • Initial release