events

Paddy 2015-12-14 Parent:ce1212549d47

5:df95f058a7b5 Go to Latest

events/stdout.go

Update to new nsqio repo. The go-nsq client is now located under a nsqio org on Github, so we need to update the import path.

History
paddy@3 1 package events
paddy@3 2
paddy@3 3 import (
paddy@3 4 "encoding/json"
paddy@3 5 "os"
paddy@3 6 )
paddy@3 7
paddy@3 8 type StdoutPublisher struct{}
paddy@3 9
paddy@3 10 func NewStdoutPublisher() StdoutPublisher {
paddy@3 11 return StdoutPublisher{}
paddy@3 12 }
paddy@3 13
paddy@3 14 func (p StdoutPublisher) Publish(topic string, e Event) error {
paddy@3 15 os.Stdout.Write([]byte(topic + ": "))
paddy@3 16 enc := json.NewEncoder(os.Stdout)
paddy@3 17 return enc.Encode(e)
paddy@3 18 }