Contents

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

require "bundler"
Bundler.setup

$:.unshift(File.expand_path("../../../lib", __FILE__))

require 'amqp'


class ConnectionInterruptionHandler

  #
  # API
  #

  def handle(connection)
    puts "[network failure] Connection #{connection} detected connection interruption"
  end

end


puts "=> Example of AMQP connection & channel recovery API in action"
puts
AMQP.start(:host => "localhost") do |connection, open_ok|
  unless connection.auto_recovering?
    puts "Connection IS NOT auto-recovering..."
  end

  ch1 = AMQP::Channel.new(connection)
  ch1.on_error do |ch, channel_close|
    raise channel_close.reply_text
  end

  unless ch1.auto_recovering?
    puts "Channel #{ch1.id} IS NOT auto-recovering"
  end
  ch1.on_connection_interruption do |c|
    puts "[network failure] Channel #{c.id} reacted to connection interruption"
  end
  ch1.on_recovery do |c|
    puts "[recovery] Channel #{c.id} has recovered"
  end


  connection.on_tcp_connection_loss do |conn, settings|
    puts "[network failure] Trying to reconnect..."
    conn.reconnect(false, 2)
  end


  handler = ConnectionInterruptionHandler.new
  connection.on_connection_interruption(&handler.method(:handle))

  connection.on_recovery do |conn, settings|
    puts "[recovery] Connection has recovered"
  end

  show_stopper = Proc.new {
    connection.disconnect { puts "Disconnected. Exiting…"; EventMachine.stop }
  }

  Signal.trap "TERM", show_stopper
  Signal.trap "INT",  show_stopper
  EM.add_timer(30, show_stopper)


  puts "Connected, authenticated. To really exercise this example, shut RabbitMQ down for a few seconds. If you don't it will exit gracefully in 30 seconds."
end

Version data entries

30 entries across 30 versions & 1 rubygems

Version	Path
amqp-1.8.0	examples/error_handling/manual_connection_and_channel_recovery.rb
amqp-1.7.0	examples/error_handling/manual_connection_and_channel_recovery.rb
amqp-1.6.0	examples/error_handling/manual_connection_and_channel_recovery.rb
amqp-1.5.3	examples/error_handling/manual_connection_and_channel_recovery.rb
amqp-1.5.2	examples/error_handling/manual_connection_and_channel_recovery.rb
amqp-1.5.1	examples/error_handling/manual_connection_and_channel_recovery.rb
amqp-1.5.0	examples/error_handling/manual_connection_and_channel_recovery.rb
amqp-1.4.2	examples/error_handling/manual_connection_and_channel_recovery.rb
amqp-1.4.1	examples/error_handling/manual_connection_and_channel_recovery.rb
amqp-1.4.0	examples/error_handling/manual_connection_and_channel_recovery.rb
amqp-1.3.0	examples/error_handling/manual_connection_and_channel_recovery.rb
amqp-1.2.1	examples/error_handling/manual_connection_and_channel_recovery.rb
amqp-1.2.0	examples/error_handling/manual_connection_and_channel_recovery.rb
amqp-1.1.8	examples/error_handling/manual_connection_and_channel_recovery.rb
amqp-1.1.7	examples/error_handling/manual_connection_and_channel_recovery.rb
amqp-1.1.6	examples/error_handling/manual_connection_and_channel_recovery.rb
amqp-1.1.5	examples/error_handling/manual_connection_and_channel_recovery.rb
amqp-1.1.4	examples/error_handling/manual_connection_and_channel_recovery.rb
amqp-1.1.3	examples/error_handling/manual_connection_and_channel_recovery.rb
amqp-1.0.4	examples/error_handling/manual_connection_and_channel_recovery.rb