diff --git a/data_sender.go b/data_sender.go index 2310844..afabb45 100644 --- a/data_sender.go +++ b/data_sender.go @@ -70,7 +70,6 @@ func (ds *DataSender) start() { func (ds *DataSender) addObservers() { go ds.handleAgentStop() - go ds.handleCollectedData() } func (ds *DataSender) Stop() {} diff --git a/data_sender_event.go b/data_sender_event.go index a527851..bef445e 100644 --- a/data_sender_event.go +++ b/data_sender_event.go @@ -9,16 +9,12 @@ func handleConfigLoaded() { ch := make(chan interface{}, 0) observer.Add(messages.CFG_LOADED, ch) startDataSender(ch) - observer.Remove(messages.CFG_LOADED, ch) + //observer.Remove(messages.CFG_LOADED, ch) } func (ds *DataSender) handleAgentStop() { ch := make(chan interface{}, 0) observer.Add(messages.AGT_STOPPED, ch) ds.Stop() - observer.Remove(messages.AGT_STOPPED, ch) -} - -func (ds *DataSender) handleCollectedData() { - + //observer.Remove(messages.AGT_STOPPED, ch) }