join room during register

This commit is contained in:
alcy 2011-08-08 13:15:18 +05:30 committed by Jordan Sissel
parent 4d7d2b5895
commit b3024c9367

View file

@ -24,12 +24,12 @@ class LogStash::Inputs::Xmpp < LogStash::Inputs::Base
if @room
require 'xmpp4r/muc/helper/simplemucclient'
@muc = Jabber::MUC::SimpleMUCClient.new(@cl)
@muc.join("#{@room}")
end
end # def register
def run(queue)
if @room
@muc.join("#{@room}")
@muc.on_message { |time,from,body|
e = to_event(body, from)
if e