connect/server/nats_test.go

package server

import (
	"testing"
	"time"

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

func TestNats_Connect(t *testing.T) {
	nc, _ := nats.Connect("nats://106.75.230.4:4333")
	msg := nats.Msg{
		Subject: "foo",
		Header: nats.Header{
			"userId": []string{uuid.NewString()},
		},
		Data: []byte("test"),
	}
	nc.PublishMsg(&msg)
	time.Sleep(10 * time.Second)
}