From b8d83c830c242778d679abcb964ad769bb3fb99e Mon Sep 17 00:00:00 2001 From: Dan Buch Date: Tue, 27 Nov 2012 00:11:56 -0500 Subject: [PATCH] Playing with round-robin behavior --- sylvilagus/jruby/lib/sylvilagus/ch04/add_points_consumer.rb | 2 +- .../jruby/lib/sylvilagus/ch04/resize_picture_consumer.rb | 5 ++--- 2 files changed, 3 insertions(+), 4 deletions(-) diff --git a/sylvilagus/jruby/lib/sylvilagus/ch04/add_points_consumer.rb b/sylvilagus/jruby/lib/sylvilagus/ch04/add_points_consumer.rb index 3831a89..5a5bf42 100644 --- a/sylvilagus/jruby/lib/sylvilagus/ch04/add_points_consumer.rb +++ b/sylvilagus/jruby/lib/sylvilagus/ch04/add_points_consumer.rb @@ -38,7 +38,7 @@ class Sylvilagus::Ch04::AddPointsConsumer channel.exchange_declare( 'upload-pictures', 'fanout', false, true, false, nil ) - channel.queue_declare('add-points', false, true, false, nil) + channel.queue_declare('add-points', false, false, false, nil) channel.queue_bind('add-points', 'upload-pictures', '') consumer = Consumer.new(channel) diff --git a/sylvilagus/jruby/lib/sylvilagus/ch04/resize_picture_consumer.rb b/sylvilagus/jruby/lib/sylvilagus/ch04/resize_picture_consumer.rb index 63546ef..a20126d 100644 --- a/sylvilagus/jruby/lib/sylvilagus/ch04/resize_picture_consumer.rb +++ b/sylvilagus/jruby/lib/sylvilagus/ch04/resize_picture_consumer.rb @@ -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?