lib/flapjack/jabber.rb in flapjack-0.6.31 vs lib/flapjack/jabber.rb in flapjack-0.6.32

- old
+ new

@@ -269,10 +269,10 @@ # FIXME: should also check if presence has been established in any group chat rooms that are # configured before starting to process events, otherwise the first few may get lost (send # before joining the group chat rooms) if connected? logger.debug("jabber is connected so commencing blpop on #{queue}") - events[queue] = @redis.blpop(queue) + events[queue] = @redis.blpop(queue, 0) event = Yajl::Parser.parse(events[queue][1]) type = event['notification_type'] logger.debug('jabber notification event received') logger.debug(event.inspect) if 'shutdown'.eql?(type)