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