Sha256: 9de2366f60610e30f07bcc3808d6da596f08ea916f93b3c75b5b71fed52ebbf8
Contents?: true
Size: 639 Bytes
Versions: 32
Compression:
Stored size: 639 Bytes
Contents
#!/usr/bin/env ruby
# encoding: utf-8
require "bundler"
Bundler.setup
$:.unshift(File.expand_path("../../../lib", __FILE__))
require 'amqp'
require 'amqp/extensions/rabbitmq'
AMQP.start(:user => 'guest',:pass => 'guest',:vhost => '/') do |connection|
channel = AMQP::Channel.new(connection)
channel.queue("shuki_q",{:nowait => true,:passive=>false, :auto_delete=>false, :arguments=>{"x-expires"=>5600000}}) do |queue|
queue.bind('raw.shuki',:routing_key => 'ShukiesTukies')
puts "before subscribe"
queue.subscribe(:ack => true) do |header, payload|
puts "inside subscribe"
p header.class
end
end
end
Version data entries
32 entries across 32 versions & 1 rubygems