fix(nats-subscribers): fix gateway nats subscribers logic (#535)

argoproj · Mar 10, 2020 · bfc53e6 · bfc53e6
1 parent 60ee618
commit bfc53e6
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/gateways/client/cloud-events.go b/gateways/client/cloud-events.go
@@ -116,9 +116,9 @@ func (gatewayContext *GatewayContext) dispatchEvent(gatewayEvent *gateways.Event
 		}
 	}
 
-	// http subscribers
+	// NATS subscribers
 	for _, subscriber := range gatewayContext.gateway.Spec.Subscribers.NATS {
-		client, ok := gatewayContext.httpSubscribers[subscriber.Name]
+		client, ok := gatewayContext.natsSubscribers[subscriber.Name]
 		if !ok {
 			gatewayContext.logger.WithField("subscriber", subscriber).Warnln("unable to send event. no client found for the subscriber")
 			completeSuccess = false