Displaying 1 result from an estimated 1 matches for "del_agent".
2009 Nov 04
4
[PATCH server] Update daemons to use new QMF.
...ent.agent_bank}.#{agent.broker.broker_bank}"
- @heartbeats[bank_key] = [agent, timestamp]
+ @heartbeats[agent.key] = [agent, timestamp]
end
end
+ def agent_added(agent)
+ @logger.info("Agent connected: #{agent.key}")
+ end
- def del_agent(agent)
+ def agent_deleted(agent)
agent_disconnected(agent)
end
# This method marks objects associated with the given agent as timed out/invalid. Called either
# when the agent heartbeats out, or we get a del_agent callback.
def agent_disconnected(agent)
+ puts &q...