From c39cfce477cf0474ff785e1598580f9f11b3326b Mon Sep 17 00:00:00 2001 From: James Mills Date: Tue, 8 May 2018 01:58:37 -0700 Subject: [PATCH] Fixe two other missed references to NewMessageBus from 22efa3a --- cmd/msgbusd/main.go | 2 +- examples/hello.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/cmd/msgbusd/main.go b/cmd/msgbusd/main.go index 7725dcc..a2c0802 100644 --- a/cmd/msgbusd/main.go +++ b/cmd/msgbusd/main.go @@ -43,7 +43,7 @@ func main() { DefaultTTL: ttl, WithMetrics: true, } - mb := msgbus.NewMessageBus(&opts) + mb := msgbus.New(&opts) http.Handle("/", mb) http.Handle("/metrics", mb.Metrics().Handler()) diff --git a/examples/hello.go b/examples/hello.go index 49a8ca7..d9490c6 100644 --- a/examples/hello.go +++ b/examples/hello.go @@ -7,7 +7,7 @@ import ( ) func main() { - m := msgbus.NewMessageBus(nil) + m := msgbus.New(nil) t := m.NewTopic("foo") m.Put(m.NewMessage(t, []byte("Hello World!")))