SCFF-29 the appender parses the event to a string, including timestamp

Author: nmillalaf

eventRouting/eventrouting.go

@@ -76,6 +76,7 @@ func (e *EventRouting) RouteEvent(msg *events.Envelope) {
 			e.selectedEventsCount["ignored_app_message"]++
 		} else {
 			//Push the event to the queue
+			fmt.Println("pushing event to queue")
 			e.queue.Push(eventQueue.NewNode(*event))
 			e.selectedEventsCount[eventType.String()]++
 

main.go

@@ -40,9 +40,10 @@ func main() {
 
 	fmt.Println("this is the sumo endpoint")
 	fmt.Println(sumoEndpoint)
+
 	//Creating queue
-	nozzleQueue := eventQueue.NewQueue(make([]*eventQueue.Node, 100))
-	loggingClientSumo := sumoCFFirehose.NewSumoLogicAppender(*sumoEndpoint, 1000, *nozzleQueue)
+	queue := eventQueue.NewQueue(make([]*eventQueue.Node, 100))
+	loggingClientSumo := sumoCFFirehose.NewSumoLogicAppender(*sumoEndpoint, 1000, *queue)
 
 	fmt.Printf("Starting firehose-to-sumo %s \n", version)
 
@@ -67,7 +68,7 @@ func main() {
 	}
 
 	//Creating Events
-	events := eventRouting.NewEventRouting(cachingClient, *loggingClientSumo, *nozzleQueue)
+	events := eventRouting.NewEventRouting(cachingClient, *loggingClientSumo, *queue)
 	err := events.SetupEventRouting(*wantedEvents)
 	if err != nil {
 		log.Fatal("Error setting up event routing: ", err)

sumoCFFirehose/sumoLogicAppender.go

@@ -8,7 +8,6 @@ import (
 	"time"
 
 	"bitbucket.org/mcplusa-ondemand/firehose-to-sumologic/eventQueue"
-	//"bitbucket.org/mcplusa-ondemand/firehose-to-sumologic/events"
 )
 
 type SumoLogicAppender struct {
@@ -46,6 +45,7 @@ func (s *SumoLogicAppender) Connect() bool {
 
 func (s *SumoLogicAppender) AppendLogs() {
 	// the appender calls for the next message in the queue and parse it to a string
+	fmt.Println("i'm in appendLogs")
 	event := s.nozzleQueue.Pop().GetNodeEvent()
 	/*
 		if event == nil {
@@ -60,7 +60,7 @@ func (s *SumoLogicAppender) AppendLogs() {
 		return
 	}
 
-	Message := time.Unix(int64(event.Fields["timestamp"].(int64)), 0).String() + "\t" + event.Fields["message_type"].(string) + "\t" + event.Msg + "\n"
+	Message := time.Unix(0, event.Fields["timestamp"].(int64)*int64(time.Nanosecond)).String() + "\t" + event.Fields["message_type"].(string) + "\t" + event.Msg + "\n"
 	fmt.Println(Message)
 	s.SendToSumo(Message)
 }