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)