NATS test

test.go

package queue_test

import (
	"os"
	"testing"

	"github.com/nats-io/gnatsd/server"
	"github.com/nats-io/gnatsd/test"
	"github.com/nats-io/nats"
)

var TestOptions = server.Options{
	Host:   "localhost",
	Port:   4222,
	NoLog:  true,
	NoSigs: true,
}

func TestMain(m *testing.M) {
	gnatsd := test.RunServer(&TestOptions)
	defer gnatsd.Shutdown()
	if gnatsd != nil {
		options := nats.DefaultOptions
		conn, err := (&options).Connect()
		if err != nil {
			panic(err)
		}
		conn.Close()
	} else {
		panic("Could not start GNATS queue server")
	}
	ret := m.Run()
	os.Exit(ret)
}

Use this..

func TestMain(m *testing.M) {
    gnatsd := test.RunServer(&TestOptions)
    defer gnatsd.Shutdown()
    if gnatsd != nil {
        url := fmt.Sprintf("nats://%s:%d", TestOptions.Host, TestOptions.Port)
        conn, err := nats.Connect(url)
        if err != nil {
            panic(err)
        }
        conn.Close()
    } else {
        panic("Could not start GNATS queue server")
    }
    ret := m.Run()
    os.Exit(ret)
}