Skip to content

Commit

Permalink
fixed codegen check
Browse files Browse the repository at this point in the history
  • Loading branch information
sysr9 committed May 21, 2024
1 parent 84db565 commit 7135b2c
Show file tree
Hide file tree
Showing 2 changed files with 1 addition and 2 deletions.
1 change: 0 additions & 1 deletion eventsources/sources/nats/start.go
Original file line number Diff line number Diff line change
Expand Up @@ -158,7 +158,6 @@ func (el *EventListener) StartListening(ctx context.Context, dispatch func([]byt
}
}


var err error
if natsEventSource.Queue != nil {
log.Infof("subscribing to messages on the subject %s queue %s", natsEventSource.Subject, *natsEventSource.Queue)
Expand Down
2 changes: 1 addition & 1 deletion eventsources/sources/nats/validate.go
Original file line number Diff line number Diff line change
Expand Up @@ -44,7 +44,7 @@ func validate(eventSource *v1alpha1.NATSEventsSource) error {
return apicommon.ValidateTLSConfig(eventSource.TLS)
}
if eventSource.Queue != nil && *eventSource.Queue == "" {
return fmt.Errorf("queue group cannot be empty if specified")
return fmt.Errorf("queue group cannot be empty if specified")
}
return nil
}

0 comments on commit 7135b2c

Please sign in to comment.