class AgentFIX::MessageCache
Public Instance Methods
add_message(msg)
click to toggle source
# File lib/agent_fix/message_cache.rb, line 10 def add_message msg lock.synchronize do msgs << msg end end
clear!()
click to toggle source
# File lib/agent_fix/message_cache.rb, line 16 def clear! lock.synchronize do msgs.clear end end
messages()
click to toggle source
# File lib/agent_fix/message_cache.rb, line 4 def messages lock.synchronize do return msgs.dup end end
Private Instance Methods
lock()
click to toggle source
# File lib/agent_fix/message_cache.rb, line 27 def lock @lock||=Mutex.new end
msgs()
click to toggle source
# File lib/agent_fix/message_cache.rb, line 23 def msgs @messages||=[] end