From 76caa9a57b96146f1d6dc370f3f93a3147c5dfd1 Mon Sep 17 00:00:00 2001 From: "R.I.Pienaar" Date: Thu, 13 Feb 2025 09:46:37 +0100 Subject: [PATCH] Create a helper for jsm options from a context Signed-off-by: R.I.Pienaar --- natscontext/context.go | 12 ++++++++++++ 1 file changed, 12 insertions(+) diff --git a/natscontext/context.go b/natscontext/context.go index 2e7893c6..1cfb1644 100644 --- a/natscontext/context.go +++ b/natscontext/context.go @@ -39,6 +39,7 @@ import ( "sort" "strings" + "github.com/nats-io/jsm.go" "github.com/nats-io/nats-server/v2/server/certstore" "github.com/nats-io/nats.go" "github.com/nats-io/nkeys" @@ -324,6 +325,17 @@ func (c *Context) Connect(opts ...nats.Option) (*nats.Conn, error) { return nats.Connect(c.ServerURL(), nopts...) } +// JSMOptions creates options for the jsm manager +func (c *Context) JSMOptions(opts ...jsm.Option) ([]jsm.Option, error) { + jsmopts := []jsm.Option{ + jsm.WithAPIPrefix(c.JSAPIPrefix()), + jsm.WithEventPrefix(c.JSEventPrefix()), + jsm.WithDomain(c.JSDomain()), + } + + return append(jsmopts, opts...), nil +} + // NATSOptions creates NATS client configuration based on the contents of the context func (c *Context) NATSOptions(opts ...nats.Option) ([]nats.Option, error) { var nopts []nats.Option