fix: NatsClient in FinalizeNats

This commit is contained in:
jar3b 2020-02-21 16:08:15 +03:00
parent b4635386bb
commit d159a8e392

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 {