You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by pc...@apache.org on 2022/06/02 08:04:13 UTC
[camel-k] 07/08: Adding test case.
This is an automated email from the ASF dual-hosted git repository.
pcongiusti pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-k.git
commit 99e8ba7016695e27176da88e88ca58d149ca112a
Author: Adriano Machado <unknown>
AuthorDate: Wed Jun 1 09:57:12 2022 -0400
Adding test case.
---
pkg/util/source/inspector_yaml_test.go | 24 +++++++++++++++++++++---
1 file changed, 21 insertions(+), 3 deletions(-)
diff --git a/pkg/util/source/inspector_yaml_test.go b/pkg/util/source/inspector_yaml_test.go
index 3ba4da8a5..1a85b1fd5 100644
--- a/pkg/util/source/inspector_yaml_test.go
+++ b/pkg/util/source/inspector_yaml_test.go
@@ -83,7 +83,7 @@ const YAMLInDepthChannel = `
uri: knative:endpoint/service
`
-const YAMLWiretapEIP = `
+const YAMLWireTapKnativeEIP = `
- from:
uri: knative:channel/mychannel
parameters:
@@ -93,6 +93,16 @@ const YAMLWiretapEIP = `
uri: knative:channel/mychannel
`
+const YAMLWireTapJmsEIP = `
+- from:
+ uri: knative:channel/mychannel
+ parameters:
+ period: "1000"
+ steps:
+ - wireTap:
+ uri: jms:queue:foo
+`
+
func TestYAMLDependencies(t *testing.T) {
tests := []struct {
name string
@@ -136,13 +146,21 @@ func TestYAMLDependencies(t *testing.T) {
},
},
{
- name: "wireTap",
- source: YAMLWiretapEIP,
+ name: "wire-tap-knative",
+ source: YAMLWireTapKnativeEIP,
dependencies: []string{
`mvn:org.apache.camel.k:camel-k-knative-producer`,
`mvn:org.apache.camel.k:camel-k-knative-consumer`,
},
},
+ {
+ name: "wire-tap-jms",
+ source: YAMLWireTapJmsEIP,
+ dependencies: []string{
+ `mvn:org.apache.camel.k:camel-k-knative-consumer`,
+ `camel:jms`,
+ },
+ },
}
for i := range tests {
test := tests[i]