Sha256: 51673b9619620f9d1e9a5b0c11c29d9a588cf8210e075498a551e12249751145
Contents?: true
Size: 768 Bytes
Versions: 1
Compression:
Stored size: 768 Bytes
Contents
#!/usr/bin/env ruby # encoding: utf-8 require "bundler" Bundler.setup $:.unshift(File.expand_path("../../../lib", __FILE__)) require 'amqp' EventMachine.run do AMQP.connect(:host => '127.0.0.1', :port => 5672) do |connection| puts "Connected to AMQP broker. Running #{AMQP::VERSION} version of the gem..." connection.on_error do |conn, connection_close| puts "Handling a connection-level exception: #{connection_close.reply_text}" EventMachine.stop end # send_frame is NOT part of the public API, but it is public for entities like AMQ::Client::Channel # and we use it here to trigger a connection-level exception. MK. connection.send_frame(AMQ::Protocol::Connection::TuneOk.encode(1000, 1024 * 128 * 1024, 10)) end end
Version data entries
1 entries across 1 versions & 1 rubygems
Version | Path |
---|---|
amqp-0.8.0.rc13 | examples/error_handling/connection_level_exception.rb |