events
2015-12-14
Parent:ce1212549d47
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.
| 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 } |