Update ruby tutorial two
This commit is contained in:
parent
7a4de0393f
commit
6c2539d737
@ -1,17 +1,15 @@
|
|||||||
#!/usr/bin/env ruby
|
#!/usr/bin/env ruby
|
||||||
# encoding: utf-8
|
require 'bunny'
|
||||||
|
|
||||||
require "bunny"
|
connection = Bunny.new(automatically_recover: false)
|
||||||
|
connection.start
|
||||||
|
|
||||||
conn = Bunny.new(:automatically_recover => false)
|
channel = connection.create_channel
|
||||||
conn.start
|
queue = channel.queue('task_queue', durable: true)
|
||||||
|
|
||||||
ch = conn.create_channel
|
message = ARGV.empty? ? 'Hello World!' : ARGV.join(' ')
|
||||||
q = ch.queue("task_queue", :durable => true)
|
|
||||||
|
|
||||||
msg = ARGV.empty? ? "Hello World!" : ARGV.join(" ")
|
queue.publish(message, persistent: true)
|
||||||
|
puts " [x] Sent #{message}"
|
||||||
|
|
||||||
q.publish(msg, :persistent => true)
|
connection.close
|
||||||
puts " [x] Sent #{msg}"
|
|
||||||
|
|
||||||
conn.close
|
|
||||||
|
Loading…
Reference in New Issue
Block a user