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 {
if StanClient == nil {
if NatsClient == nil {
return fmt.Errorf("stan client is not initialized")
}
for _, subscription := range *subscriptions {