INNER CODE UNIT · Go

createJStream

shijuvar/go-distributed-sys · eventstream/bootstrapper/main.go:27

func createJStream(streamName string, streamSubjects string) error {
	natsComponent := natsutil.NewNATSComponent("bootstrapper")
	err := natsComponent.ConnectToServer(nats.DefaultURL)
	if err != nil {
		log.Fatal(err)
	}
	var js nats.JetStreamContext
	js, err = natsComponent.JetStreamContext()
	if err != nil {
		log.Fatalln(err)
	}
	// Check if the ORDERS stream already exists; if not, create it.
	stream, err := js.StreamInfo(streamName)
	if err != nil {
		log.Println(err)
	}
	if stream == nil {
		log.Printf("creating stream %q and subjects %q", streamName, streamSubjects)

View source record →