diff --git a/agent.go b/agent.go index 6aa1a2c..4969f80 100644 --- a/agent.go +++ b/agent.go @@ -98,7 +98,7 @@ func (agt *Agent) startAgent() { <-colStarted //8.evt result - res := msg.Event{msg.EVT_TYPE_NONE, msg.AGT_START, nil} + res := msg.Event{msg.EVT_TYPE_NONE, msg.EVENT_AGT_START, nil} evt.AddEventData(res) go agt.processCollectingData(dataCh) @@ -122,7 +122,7 @@ func (agt *Agent) waitAgentTask() { d := <-agt.taskCh task := d.(msg.AgentTask) switch task.Command { - case msg.TASK_POLLER_INTERVAL_UPDATE: + case msg.TASK_POL_INTERVAL_UPDATE: agt.processUpdatePolInterval(task) break case msg.TASK_SENSOR_START: @@ -190,7 +190,7 @@ func (agt *Agent) stopAgent() { } <-polStopped - evt.AddEventData(msg.Event{msg.EVT_TYPE_NONE, msg.AGT_STOP, nil}) + evt.AddEventData(msg.Event{msg.EVT_TYPE_NONE, msg.EVENT_AGT_STOP, nil}) evt.Stop() }