Sha256: a318fb4286a621e2bc9053ef369a2e6c83b8f859f030ff7d76d0a8c4121dbf68
Contents?: true
Size: 541 Bytes
Versions: 64
Compression:
Stored size: 541 Bytes
Contents
#!/usr/bin/env ruby # encoding: utf-8 require "bundler" Bundler.setup $:.unshift(File.expand_path("../../../lib", __FILE__)) require 'amqp' puts "=> Channel#initialize example that uses a block" puts AMQP.start(:host => 'localhost') do |connection| AMQP::Channel.new do |channel, open_ok| puts "Channel ##{channel.id} is now open!" end show_stopper = Proc.new do $stdout.puts "Stopping..." connection.close { EM.stop { exit } } end Signal.trap "INT", show_stopper EM.add_timer(2, show_stopper) end
Version data entries
64 entries across 64 versions & 1 rubygems