From 5776baad3705f6bd966b679bb353f23ab4c04e5b Mon Sep 17 00:00:00 2001 From: postmannen Date: Fri, 29 Nov 2024 13:55:54 +0100 Subject: [PATCH] set jetstream=true in nats server for testing --- requests_test.go | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/requests_test.go b/requests_test.go index 391355c..ece76f7 100644 --- a/requests_test.go +++ b/requests_test.go @@ -93,8 +93,9 @@ func newServerForTesting(addressAndPort string, testFolder string) (*server, *Co func newNatsServerForTesting(port int) *natsserver.Server { // Start up the nats-server message broker. nsOpt := &natsserver.Options{ - Host: "127.0.0.1", - Port: port, + Host: "127.0.0.1", + Port: port, + JetStream: true, } ns, err := natsserver.NewServer(nsOpt)