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