Fix apache#645: use the right kind of sink in knative trait

nicolaferraro · May 7, 2019 · 556221c · 556221c
1 parent 96c746a
commit 556221c
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/pkg/trait/knative.go b/pkg/trait/knative.go
@@ -71,15 +71,15 @@ func (t *knativeTrait) Configure(e *Environment) (bool, error) {
 
 			t.ChannelSources = strings.Join(items, ",")
 		}
-		if t.EndpointSinks == "" {
+		if t.ChannelSinks == "" {
 			items := make([]string, 0)
 
 			metadata.Each(e.CamelCatalog, e.Integration.Spec.Sources, func(_ int, meta metadata.IntegrationMetadata) bool {
 				items = append(items, knativeutil.ExtractChannelNames(meta.ToURIs)...)
 				return true
 			})
 
-			t.EndpointSinks = strings.Join(items, ",")
+			t.ChannelSinks = strings.Join(items, ",")
 		}
 		if t.EndpointSources == "" {
 			items := make([]string, 0)