Initially I was using one thread to listen a queue from amazon and works perfectly.
aws.rb
Thread.new do
queue = AWS::SQS::Queue.new(SQSADDR['my_queue'])
queue.poll do |msg|
...
but now I appended another thread to listen another queue:
...
Thread.new do
queue = AWS::SQS::Queue.new(SQSADDR['my_another_queue'])
queue.poll do |msg|
...
and now it seems to not work. Only the last one receives response...
What is going on?
Are you overwriting the variable queue
?
If you love us? You can donate to us via Paypal or buy me a coffee so we can maintain and grow! Thank you!
Donate Us With