Sha256: 206ebae8ef2c0285dbab6b381c57415d4c4260425dc887dfb40aa1a2da26912a
Contents?: true
Size: 990 Bytes
Versions: 24
Compression:
Stored size: 990 Bytes
Contents
require "bundler" Bundler.setup Bundler.require(:default) $LOAD_PATH.unshift(File.expand_path("../../../lib", __FILE__)) require "amq/client/adapters/coolio" require "amq/client/queue" require "amq/client/exchange" if RUBY_VERSION.to_s =~ /^1.9/ Encoding.default_internal = Encoding::UTF_8 Encoding.default_external = Encoding::UTF_8 end def amq_client_example(description = "", &block) AMQ::Client::CoolioClient.connect(:port => 5672, :vhost => "/amq_client_testbed") do |client| begin puts puts puts "=============> #{description}" block.call(client) rescue Interrupt warn "Manually interrupted, terminating ..." rescue Exception => exception STDERR.puts "\n\e[1;31m[#{exception.class}] #{exception.message}\e[0m" exception.backtrace.each do |line| line = "\e[0;36m#{line}\e[0m" if line.match(Regexp::quote(File.basename(__FILE__))) STDERR.puts " - " + line end end end cool.io.run end
Version data entries
24 entries across 24 versions & 1 rubygems