How to publish and consume JSON data?

[kharabela]

I am only able to publish string data as of now.Using js.PublishAsync("Subjects.AccountInfo", []byte(data))

Here is format of sample data I want to publish
{ "data": [ { "type": "account", "id": "1", "attributes": { "name": "Name 1", "age": "22" }, "relationships": { "party": { "data": { "id": "1", "type": "people" } } } } ] }
Below is my sample code

package main
import (
	"fmt"
	"log"
	`"time"`
	"github.com/nats-io/nats.go"
)

func CreateStream(jetStream nats.JetStreamContext, subject string) {
	stream, err := jetStream.StreamInfo("Subjects.AccountInfo")

	// stream not found, create it
	if stream == nil {
		log.Printf("Creating stream: %s\n", "Subjects.AccountInfo")
		_, err = jetStream.AddStream(&nats.StreamConfig{
			Name:     "Subjects",
			Subjects: []string{"Subjects.AccountInfo"},
		})

		if err != nil {
			log.Printf("Error Occurred: %s\n", err.Error())
		}
	}
}

func JetStreamAccountInit(data string) {
	nc, err := nats.Connect(nats.DefaultURL)
	if err != nil {
		log.Fatal(err)
	}
	defer nc.Close()

	// Use the JetStream context to produce and consumer messages
	// that have been persisted.

	js, err := nc.JetStream(nats.PublishAsyncMaxPending(256))//ec, err := nats.NewEncodedConn(nc, nats.JSON_ENCODER)
	if err != nil {
		log.Fatal(err)
	}

	// Create a stream if it does not exist
	CreateStream(js, "Subjects.AccountInfo")

	js.PublishAsync("Subjects.AccountInfo", []byte(data))
	select {
	case <-js.PublishAsyncComplete():
	case <-time.After(5 * time.Second):
		fmt.Println("Did not resolve in time")
	}

}

[neilalexander]

JetStream doesn't care about strings vs encoded formats, you just provide a some bytes.

Therefore just encode your JSON before you publish it:

foo := struct{
  Bar string `json:"bar"`
}{
  Bar: "baz",
}

j, err := json.Marshal(foo)
if err != nil {
  ...
}

// "j" is []byte here

_, err = js.PublishAsync("subject", j)
if err != nil {
  ...
}