stale/nacl
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: add SetupJetStream()

Browse Source
This commit is contained in:
jar3b 2021-06-07 14:02:59 +03:00
parent e8cba551c7
commit 5cf7a062b9
1 changed files with 19 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
nacl.go
View File

@ -12,6 +12,7 @@ import (
var ( var (
NatsClient *nats.Conn NatsClient *nats.Conn
StanClient stan.Conn StanClient stan.Conn
JsClient nats.JetStreamContext
natsLock = sync.Mutex{} natsLock = sync.Mutex{}
stanLock = sync.Mutex{} stanLock = sync.Mutex{}
) )
@ -40,6 +41,20 @@ func SetupNatsWithCreds(host string, port int, credsFile string, closeHandler *g
return nil return nil
} }
func SetupJetStream(host string, port int, credsFile string, closeHandler *grawt.CloseHandler, opts ...nats.JSOpt) error {
var err error
if err := SetupNatsWithCreds(host, port, credsFile, closeHandler); err != nil {
return err
}
JsClient, err = NatsClient.JetStream(opts...)
if err != nil {
return fmt.Errorf("Cannot init JS: %v", err)
}
return nil
}
func SetupNats(host string, port int, user string, pass string, closeHandler *grawt.CloseHandler) error { func SetupNats(host string, port int, user string, pass string, closeHandler *grawt.CloseHandler) error {
natsLock.Lock() natsLock.Lock()
defer natsLock.Unlock() defer natsLock.Unlock()
@ -128,3 +143,7 @@ func FinalizeNats(subscriptions *[]*nats.Subscription) error {
return nil return nil
} }
func FinalizeJetStream(subscriptions *[]*nats.Subscription) error {
return FinalizeNats(subscriptions)
}