1#!/env ruby
 2# encoding: utf-8
 3
 4require "bunny"
 5
 6connection = Bunny.new
 7connection.start
 8
 9channel = connection.create_channel
10queue = channel.queue("task_queue", durable: true)
11
12message  = ARGV.empty? ? "Hello World!" : ARGV.join(" ")
13queue.publish(message, persistent: true)
14puts " [x] Sent #{message}"
15sleep 1.0
16connection.close