|
|
|
@ -40,13 +40,12 @@ class Sylvilagus::Ch04::ResizePictureConsumer
|
|
|
|
|
channel.exchange_declare(
|
|
|
|
|
'upload-pictures', 'fanout', false, true, false, nil
|
|
|
|
|
)
|
|
|
|
|
channel.queue_declare('resize-picture', false, true, false, nil)
|
|
|
|
|
channel.queue_declare('resize-picture', false, false, false, nil)
|
|
|
|
|
channel.queue_bind('resize-picture', 'upload-pictures', '')
|
|
|
|
|
|
|
|
|
|
consumer = Consumer.new(channel)
|
|
|
|
|
puts "Consuming from 'upload-pictures' exchange"
|
|
|
|
|
channel.basic_consume('resize-picture', false,
|
|
|
|
|
"resize-picture-consumer-#{$$}-#{ENV['HOSTNAME']}",
|
|
|
|
|
channel.basic_consume('resize-picture', false, 'resize-picture-consumer',
|
|
|
|
|
false, false, nil, consumer)
|
|
|
|
|
loop do
|
|
|
|
|
break if consumer.done?
|
|
|
|
|