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