fixed interface change on sse library and added gitignore

ernestio · Jul 6, 2017 · 480451d · 480451d
1 parent ce6ffa4
commit 480451d
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/.gitignore b/.gitignore
@@ -0,0 +1 @@
+monit
diff --git a/notification.go b/notification.go
@@ -10,6 +10,7 @@ import (
 	"strings"
 
 	"github.com/nats-io/nats"
+	"github.com/r3labs/sse"
 )
 
 // Messages holds a collection of the type Message
@@ -42,7 +43,6 @@ func (n *Notification) getServiceID() string {
 
 func processNotification(notification *Notification, msg *nats.Msg) error {
 	return json.Unmarshal(msg.Data, &notification)
-
 }
 
 func publishMessage(service string, msg *Message) {
@@ -52,6 +52,6 @@ func publishMessage(service string, msg *Message) {
 		log.Println("Could not encode message: ")
 		log.Println(err)
 	} else {
-		s.Publish(service, data)
+		s.Publish(service, &sse.Event{Data: data})
 	}
 }