From 3aff00acc54e925ee7ad7fcc35190f0bc0f2356f Mon Sep 17 00:00:00 2001 From: "insanity@loafle.com" Date: Thu, 11 May 2017 20:07:31 +0900 Subject: [PATCH] data_sender --- data_sender.go | 1 - data_sender_event.go | 8 ++------ 2 files changed, 2 insertions(+), 7 deletions(-) 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) }