Consume from multiple topics into a single queue

multitopic.rb

require 'nsq'
require 'thread'

queue = Queue.new

consumer_for_topic1 = Nsq::Consumer.new(
  topic: 'topic1',
  channel: 'multi-topic-consumer',
  queue: queue
)

consumer_for_topic2 = Nsq::Consumer.new(
  topic: 'topic1',
  channel: 'multi-topic-consumer',
  queue: queue
)

loop do
  msg = queue.pop
  puts msg.body
  msg.finish
end