event test

event_sender.go

@@ -8,6 +8,14 @@ import (
 	q "loafle.com/overflow/queue_go"
 	"log"
 	"reflect"
+	"loafle.com/overflow/agent_api/observer"
+	"sync"
+)
+
+
+var (
+	instance *EventSender
+	once     sync.Once
 )
 
 const (
@@ -24,12 +32,38 @@ type Data struct {
 	FinishedAt uint64
 }
 
+
+func GetInstance() *EventSender {
+	once.Do(func() {
+		instance = &EventSender{}
+	})
+	return instance
+}
+
+func init()  {
+	ch := make(chan interface{}, 0)
+	observer.Add(messages.CONFIGMANAGER_LOADED, ch)
+	handleInit(ch)
+}
+
+func handleInit(ch chan interface{}) {
+	es := GetInstance()
+	go func() {
+		data := <-ch
+		log.Println("handleInit", data)
+		//ds.gconf = data.(cm.ConfigManager).GetGlobalConfig()
+		es.start()
+		close(ch)
+	}()
+}
+
 type EventSender struct {
+	once  sync.Once
 	lq *q.LoafleQueue
 	sc chan interface{}
 }
 
-func (es *EventSender) Start() {
+func (es *EventSender) start() {
 	es.sc = make(chan interface{}, 0)
 
 	es.lq = q.NewQueue(messages.QUEUE_EVENT, DEFAULT_INTERVAL, es.sc)

event_sender_test.go

@@ -11,11 +11,13 @@ import (
 
 func TestEventSender_Start(t *testing.T) {
 
-	es := &EventSender{}
+	observer.Notify("CONFIGMANAGER_LOADED", nil)
-	es.Start()
+
+	time.Sleep(time.Second * 5)
+
 	testNotify()
 
-	time.Sleep(time.Second * 1000)
+	time.Sleep(time.Second * 100)
 
 }