Subscribe all messages

sub-all.go

package main

import (
	"fmt"
	"time"

	"github.com/nats-io/stan.go"
)

func main() {
	sc, err := stan.Connect("test-cluster", "sub2", stan.NatsURL("localhost:4222"))
	if err != nil {
		panic(err.Error())
	}

	sub, _ := sc.Subscribe("novo", func(m *stan.Msg) {
		fmt.Printf("Received a message: %s\n", string(m.Data))
	}, stan.DeliverAllAvailable())
	// Close connection

	time.Sleep(40 * time.Second)

	sub.Close()
}