ruby – EventMachine和em-websocket – 从队列中读取并推送到频

我正在使用eventmachine从HornetQ主题中读取,推送到由EM websocket连接订阅的Channel.我需要阻止@ topic.receive循环阻塞,所以创建了一个proc并且调用EventMachine.defer而没有回调.这将无限期地运行.这很好用.我也可以使用Thread.new.

我的问题是,这是从流/队列中读取并将数据传递到通道的正确方法吗？有更好的/任何其他方法来做到这一点吗？

require 'em-websocket'
require 'torquebox-messaging'

class WebsocketServer

  def initialize
    @channel = EM::Channel.new

    @topic = TorqueBox::Messaging::Topic.new('/topics/mytopic')
  end 

  def start
    EventMachine.run do

      topic_to_channel = proc do
        while true
          msg = @topic.receive
          @channel.push msg
        end
      end

      EventMachine.defer(topic_to_channel)

      EventMachine::WebSocket.start(:host => "127.0.0.1",:port => 8081,:debug => false) do |connection|
        connection.onopen do

          sid = @channel.subscribe { |msg| connection.send msg }

          connection.onclose do            
            @channel.unsubscribe(sid)
          end
        end
      end                  
    end
  end
end

WebsocketServer.new.start