16 lines
340 B
Ruby
16 lines
340 B
Ruby
#!/usr/bin/env ruby
|
|
require 'bunny'
|
|
|
|
connection = Bunny.new(automatically_recover: false)
|
|
connection.start
|
|
|
|
channel = connection.create_channel
|
|
queue = channel.queue('task_queue', durable: true)
|
|
|
|
message = ARGV.empty? ? 'Hello World!' : ARGV.join(' ')
|
|
|
|
queue.publish(message, persistent: true)
|
|
puts " [x] Sent #{message}"
|
|
|
|
connection.close
|