How to enable jet stream in nats test server? #4788
-
I'm using But in my code I also use jet stream and I wanted to test nats jet stream functionality, But I'm having some errors. import natsserver "github.com/nats-io/nats-server/v2/test"
func TestJS(t *testing.T) {
s := natsserver.RunServer(natsserver.DefaultTestOptions)
defer s.Shutdown()
nc, err := nats.Connect(s.Addr().String())
assert.NoError(t, err)
jsConn, err := nc.JetStream()
assert.NoError(t, err)
js := NewJetstream(nc, jsConn, []nats.SubOpt{})
defer js.Close()
ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
defer cancel()
_, err = js.jconn.AddStream(&nats.StreamConfig{Name: "test_stream"}, nats.ContextOpt{Context: ctx})
assert.NoError(t, err)
} And I'm getting this error: I also have gotten error I think |
Beta Was this translation helpful? Give feedback.
Replies: 1 comment
-
Sorry my bad! I was using an outdated version of Updated from |
Beta Was this translation helpful? Give feedback.
Sorry my bad! I was using an outdated version of
nats-server
.Updated from
2.1.9 to 2.10.5
and everything is fine now.