Hi<br><br>This is our current setup that is working in a server:<br>Listener (that receives the data and publishes it):<br><b>module QueueData<br> def receive_data(d)<br> $amq.queue("queue_name").publish(d)<br>
end<br>end<div class="im"><br>EM.run {<br> $amq = MQ.new<br></div> EM.start_server "0.0.0.0", 22003, QueueData <br>}</b><br><br>Processor (that subscribes to the queue and processes it):<br><b>EM.run { <br>
amq = MQ.new<br>
amq.queue("queue_name").subscribe { |d|<br> puts d <br> }<br>}</b><br><br>How do I subscribe to this queue from another machine? I tried this:<br><b>AMQP.start(:host => 'hostname', :port => 5672, :logging => true) do<br>
puts "connected ..."<br> mq = MQ.new<br> MQ.queue('queue_name').subscribe{ |msg|<br> puts msg<br> }<br>end</b><br><br>But it doesn't work. Any suggestions?<br>