Skip to content

Commit

Permalink
updated event subjects
Browse files Browse the repository at this point in the history
  • Loading branch information
purehyperbole committed Sep 15, 2017
1 parent bcaa749 commit 283eefa
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions service.go
Original file line number Diff line number Diff line change
Expand Up @@ -40,11 +40,11 @@ func processService(msg *nats.Msg) {
}

switch msg.Subject {
case "service.create", "service.delete", "service.import":
case "build.create", "build.delete", "build.import":
log.Println("Creating stream: ", id)
ss.CreateStream(id)
ss.Publish(id, &sse.Event{Data: data})
case "service.create.done", "service.create.error", "service.delete.done", "service.delete.error", "service.import.done", "service.import.error":
case "build.create.done", "build.create.error", "build.delete.done", "build.delete.error", "build.import.done", "build.import.error":
ss.Publish(id, &sse.Event{Data: data})
go func(ss *sse.Server) {
// Wait for any late connecting clients before closing stream
Expand Down

0 comments on commit 283eefa

Please sign in to comment.