support domain in jsm

Signed-off-by: R.I.Pienaar <[email protected]>

jsm.go

@@ -112,7 +112,11 @@ func IsValidName(n string) bool {
 }
 
 // APISubject returns API subject with prefix applied
-func APISubject(subject string, prefix string) string {
+func APISubject(subject string, prefix string, domain string) string {
+	if domain != "" {
+		return fmt.Sprintf("$JS.%s.API", domain)
+	}
+
 	if prefix == "" {
 		return subject
 	}

manager.go

@@ -35,6 +35,7 @@ type Manager struct {
 	validator   api.StructValidator
 	apiPrefix   string
 	eventPrefix string
+	domain      string
 
 	sync.Mutex
 }
@@ -444,7 +445,7 @@ func (m *Manager) Streams() (streams []*Stream, err error) {
 }
 
 func (m *Manager) apiSubject(subject string) string {
-	return APISubject(subject, m.apiPrefix)
+	return APISubject(subject, m.apiPrefix, m.domain)
 }
 
 // MetaLeaderStandDown requests the meta group leader to stand down, must be initiated by a system user

natscontext/context.go

@@ -554,13 +554,7 @@ func WithJSAPIPrefix(p string) Option {
 }
 
 // JSAPIPrefix is the subject prefix to use when accessing JetStream API
-func (c *Context) JSAPIPrefix() string {
-	if c.config.JSDomain != "" {
-		return fmt.Sprintf("$JS.%s.API", c.config.JSDomain)
-	}
-
-	return c.config.JSAPIPrefix
-}
+func (c *Context) JSAPIPrefix() string { return c.config.JSAPIPrefix }
 
 // WithJSEventPrefix sets the prefix to use for JetStream Events
 func WithJSEventPrefix(p string) Option {

options.go

@@ -56,3 +56,10 @@ func WithEventPrefix(s string) Option {
 		o.eventPrefix = s
 	}
 }
+
+// WithDomain sets a JetStream domain, incompatible with WithApiPrefix()
+func WithDomain(d string) Option {
+	return func(o *Manager) {
+		o.domain = d
+	}
+}