Does jetstream work with the embedded test server?

[jkwatson-verta]

I'm trying to use the test server from "github.com/nats-io/nats-server/test". It works fine with bare NATS, but when I try to add a jetstream stream, it fails with a "context deadline exceeded" error. There doesn't appear to be an option to enable Jetstream in the options that are available.

Sample code:

import (
	"github.com/nats-io/gnatsd/server"
	natsServer "github.com/nats-io/nats-server/test"
	"github.com/nats-io/nats.go"
	"testing"
)

func TestEmbeddedJetstream(t *testing.T) {
        opts := &natsServer.DefaultTestOptions
	opts.Port = server.RANDOM_PORT

	embeddedServer := natsServer.RunServer(opts)
	defer embeddedServer.Shutdown()

	serverAddress := embeddedServer.Addr().String()
	connection, err := nats.Connect("nats://"+serverAddress, nats.RetryOnFailedConnect(true))
	if err != nil {
		t.Fatal(err)
	}

	jetstream, err := connection.JetStream()
	if err != nil {
		t.Fatal(err)
	}
	_, err = jetstream.AddStream(&nats.StreamConfig{Name: "test_stream"})
	if err != nil {
		t.Fatal(err)
	}
}

[derekcollison]

Change "github.com/nats-io/gnatsd/server" to "github.com/nats-io/nats-server/v2/server"

[jkwatson-verta]

That doesn't work, because test.RunServer() returns the gnatsd server. Are you saying not to use github.com/nats-io/nats-server/test at all?

[derekcollison]

import natsServer "github.com/nats-io/nats-server/v2/test"

Try that..

[jkwatson-verta]

awesome. that worked. Thanks a million!

[a-h]

I couldn't quite work out from the sample how to get this working, but I found nats-io/nats.go#467 (comment) and got that up and running.