Method: ZK::MessageQueue#poll!

Defined in:
lib/zk/message_queue.rb

#poll! ⇒ Object

grab one message from the queue

used when you don't want to or can't subscribe

See Also:

  • ZooKeeper::MessageQueue#subscribe


78
79
80
 
# File 'lib/zk/message_queue.rb', line 78

def poll!
  find_and_process_next_available(messages)
end