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    => "/a/b/c/#{rand}/d/#{Time.now.to_i}",
                                            :user     => "amq_client_gem",
                                            :password => "amq_client_gem_password",
                                            :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

46 entries across 46 versions & 1 rubygems

Version	Path
amq-client-0.7.0.alpha27	examples/eventmachine_adapter/authentication/connection_open_failure_due_to_invalid_vhost.rb
amq-client-0.7.0.alpha26	examples/eventmachine_adapter/authentication/connection_open_failure_due_to_invalid_vhost.rb
amq-client-0.7.0.alpha25	examples/eventmachine_adapter/authentication/connection_open_failure_due_to_invalid_vhost.rb
amq-client-0.7.0.alpha24	examples/eventmachine_adapter/authentication/connection_open_failure_due_to_invalid_vhost.rb
amq-client-0.7.0.alpha23	examples/eventmachine_adapter/authentication/connection_open_failure_due_to_invalid_vhost.rb
amq-client-0.7.0.alpha22	examples/eventmachine_adapter/authentication/connection_open_failure_due_to_invalid_vhost.rb