Sha256: 6d1bd1fd679e29985d527d10a9f5660cd2705354253ea0c67a2fb49d6291599e
Contents?: true
Size: 397 Bytes
Versions: 6
Compression:
Stored size: 397 Bytes
Contents
# encoding: utf-8
require "amq/client/async/extensions/rabbitmq/cancel"
# Basic.Nack
module AMQ
module Client
# backwards compatibility
# @private
Extensions = Async::Extensions unless defined?(Extensions)
module Settings
CLIENT_PROPERTIES[:capabilities] ||= {}
CLIENT_PROPERTIES[:capabilities][:consumer_cancel_notify] = true
end
end # Client
end # AMQ
Version data entries
6 entries across 6 versions & 1 rubygems