Fix panic bug

cmd/msgbus/pull.go

@@ -46,5 +46,7 @@ func pull(client *client.Client, topic string) {
 		fmt.Fprintf(os.Stderr, "error reading message: %s\n", err)
 		os.Exit(2)
 	}
-	fmt.Printf("%s\n", msg.Payload)
+	if msg != nil {
+		fmt.Printf("%s\n", msg.Payload)
+	}
 }

msgbus.go

@@ -376,7 +376,7 @@ func (mb *MessageBus) Put(message Message) error {
 			return fmt.Errorf("error creating logfile filename for %s: %w", t.Name, err)
 		}
 
-		l, err := wal.Open(fn, nil)
+		l, err = wal.Open(fn, nil)
 		if err != nil {
 			return fmt.Errorf("error opening logfile %s: %w", fn, err)
 		}
@@ -573,7 +573,7 @@ func (mb *MessageBus) ServeHTTP(w http.ResponseWriter, r *http.Request) {
 	topic := strings.Trim(r.URL.Path, "/")
 
 	t := mb.NewTopic(topic)
-	log.Debugf("request for topic %#v", t.Name)
+	log.Debugf("request for topic %s", t.Name)
 
 	switch r.Method {
 	case "POST", "PUT":