Now that Bunny::Connection#close performs clean shutdowns, these can go
This commit is contained in:
parent
b6c7fe0797
commit
c1aa2d8e78
@ -14,5 +14,4 @@ msg = ARGV.empty? ? "Hello World!" : ARGV.join(" ")
|
||||
x.publish(msg)
|
||||
puts " [x] Sent #{msg}"
|
||||
|
||||
sleep 0.5
|
||||
conn.close
|
||||
|
@ -14,5 +14,4 @@ msg = ARGV.empty? ? "Hello World!" : ARGV.join(" ")
|
||||
x.publish(msg, :routing_key => severity)
|
||||
puts " [x] Sent '#{msg}'"
|
||||
|
||||
sleep 0.5
|
||||
conn.close
|
||||
|
@ -14,5 +14,4 @@ msg = ARGV.empty? ? "Hello World!" : ARGV.join(" ")
|
||||
x.publish(msg, :routing_key => severity)
|
||||
puts " [x] Sent #{severity}:#{msg}"
|
||||
|
||||
sleep 0.5
|
||||
conn.close
|
||||
|
@ -14,5 +14,4 @@ msg = ARGV.empty? ? "Hello World!" : ARGV.join(" ")
|
||||
q.publish(msg, :persistent => true)
|
||||
puts " [x] Sent #{msg}"
|
||||
|
||||
sleep 1.0
|
||||
conn.close
|
||||
|
@ -12,5 +12,4 @@ q = ch.queue("hello")
|
||||
ch.default_exchange.publish("Hello World!", :routing_key => q.name)
|
||||
puts " [x] Sent 'Hello World!'"
|
||||
|
||||
sleep 0.5
|
||||
conn.close
|
||||
|
Loading…
Reference in New Issue
Block a user