Contents

#!/usr/bin/env ruby
# encoding: utf-8

__dir = File.join(File.dirname(File.expand_path(__FILE__)))
require File.join(__dir, "example_helper")

begin
  EventMachine.run do

    show_stopper = Proc.new {
      EM.stop
    }

    Signal.trap "INT",  show_stopper
    Signal.trap "TERM", show_stopper

    EventMachine.add_timer(4, show_stopper)

    AMQ::Client::EventMachineClient.connect(:port     => 9689,
                                            :vhost    => "/amq_client_testbed",
                                            :user     => "amq_client_gem",
                                            :password => "amq_client_gem_password",
                                            :connection_timeout        => 0.3) do |client|
      raise "Connected, authenticated. This is not what this example is supposed to do!"
    end
  end
rescue AMQ::Client::TCPConnectionFailed => e
  puts "TCP connection has failed, as expected. Shutting down…"
  EventMachine.stop if EventMachine.reactor_running?
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
amq-client-0.7.0.alpha5	examples/eventmachine_adapter/connection_failure_exception.rb
amq-client-0.7.0.alpha4	examples/eventmachine_adapter/connection_failure_exception.rb
amq-client-0.7.0.alpha3	examples/eventmachine_adapter/connection_failure_exception.rb
amq-client-0.7.0.alpha2	examples/eventmachine_adapter/connection_failure_exception.rb