1 Commits

Author SHA1 Message Date
jar3b
d159a8e392 fix: NatsClient in FinalizeNats 2020-02-21 16:08:15 +03:00

View File

@@ -80,7 +80,7 @@ func FinalizeStan(subscriptions *[]Subscription) error {
} }
func FinalizeNats(subscriptions *[]*NatsSubscription) error { func FinalizeNats(subscriptions *[]*NatsSubscription) error {
if StanClient == nil { if NatsClient == nil {
return fmt.Errorf("stan client is not initialized") return fmt.Errorf("stan client is not initialized")
} }
for _, subscription := range *subscriptions { for _, subscription := range *subscriptions {