Sha256: 0dcd3c770ba57937c3c3048406f3d5bbe1d14c4693646da786713eb5305b5b52
Contents?: true
Size: 947 Bytes
Versions: 63
Compression:
Stored size: 947 Bytes
Contents
#!/usr/bin/env ruby # encoding: utf-8 require "bundler" Bundler.setup $:.unshift(File.expand_path("../../../lib", __FILE__)) require 'amqp' puts "=> Authentication failure handling with a callback" puts handler = Proc.new { |settings| puts "Failed to connect, as expected"; EM.stop } connection_settings = { :port => 5672, :vhost => "/amq_client_testbed", :user => "amq_client_gem", :password => "amq_client_gem_password_that_is_incorrect #{Time.now.to_i}", :timeout => 0.3, :on_tcp_connection_failure => handler, :on_possible_authentication_failure => Proc.new { |settings| puts "Authentication failed, as expected, settings are: #{settings.inspect}" EM.stop } } AMQP.start(connection_settings) do |connection, open_ok| raise "This should not be reachable" end
Version data entries
63 entries across 63 versions & 1 rubygems