NATS Publisher

publisher.go

package main

import (
	"log"
	"time"

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

type Msg struct {
	Subject string
	Body    []byte
}

func main() {
	nc, _ := nats.Connect(nats.DefaultURL)
	ec, _ := nats.NewEncodedConn(nc, nats.JSON_ENCODER)

	msg := Msg{
		Subject: "Hello World",
		Body:    []byte("Hello!"),
	}

	log.Println("Running publisher")
	for {
		ec.Publish("heartbeat", msg)
		time.Sleep(time.Second * 5)
	}
}