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
      puts "Updating client properties"
      CLIENT_PROPERTIES[:capabilities] ||= {}
      CLIENT_PROPERTIES[:capabilities][:consumer_cancel_notify] = true
    end
  end # Client
end # AMQ

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
amq-client-0.9.5	lib/amq/client/extensions/rabbitmq/cancel.rb