module AgentZMQ::MessageCache
Public Instance Methods
add_msg(msg)
click to toggle source
# File lib/agent_zmq/message_cache.rb, line 15 def add_msg msg lock.synchronize do messages << msg end end
clear()
click to toggle source
# File lib/agent_zmq/message_cache.rb, line 21 def clear lock.synchronize do messages.clear end end
messages_received()
click to toggle source
# File lib/agent_zmq/message_cache.rb, line 3 def messages_received lock.synchronize do return messages.dup end end
pop()
click to toggle source
# File lib/agent_zmq/message_cache.rb, line 9 def pop lock.synchronize do return messages.pop end end
Private Instance Methods
lock()
click to toggle source
# File lib/agent_zmq/message_cache.rb, line 33 def lock @lock||=Mutex.new end
messages()
click to toggle source
# File lib/agent_zmq/message_cache.rb, line 29 def messages @messages||=[] end