Sha256: 75cac0fc7a18752a4e1b212eb7c39ef89957fe4ed8c5c5af923bc8f5682113c3
Contents?: true
Size: 543 Bytes
Versions: 27
Compression:
Stored size: 543 Bytes
Contents
require "amq/client/adapters/event_machine"
require "amq/client/queue"
require "amq/client/exchange"
require "evented-spec"
case RUBY_VERSION
when "1.8.7" then
class Array
alias sample choice
end
when /^1.9/ then
Encoding.default_internal = Encoding::UTF_8
Encoding.default_external = Encoding::UTF_8
end
def em_amqp_connect(&block)
em do
AMQ::Client::EventMachineClient.connect(:port => 5672, :vhost => "/amq_client_testbed", :frame_max => 65536, :heartbeat_interval => 1) do |client|
yield client
end
end
end
Version data entries
27 entries across 27 versions & 1 rubygems