Fixe two other missed references to NewMessageBus from 22efa3a

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())

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!")))