Nats publish

pub.go

package main

import (
	"os"

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

func main() {
	sc, err := stan.Connect("test-cluster", "client1", stan.NatsURL("localhost:4222"))
	if err != nil {
		panic(err.Error())
	}
	// Simple Synchronous Publisher
	err = sc.Publish("novo", []byte(os.Args[1])) // does not return until an ack has been received from NATS Streaming
	if err != nil {
		panic(err.Error())
	}
	// Close connection
	sc.Close()
}