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:09 UTC
[camel-k] 03/08: Kotlin DSL support for wireTap
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 3ea86a7c25a999063aee6866034531133611e78b
Author: Adriano Machado <unknown>
AuthorDate: Mon May 30 12:06:55 2022 -0400
Kotlin DSL support for wireTap
---
pkg/util/source/inspector_kotlin.go | 1 +
pkg/util/source/inspector_kotlin_test.go | 9 +++++++++
2 files changed, 10 insertions(+)
diff --git a/pkg/util/source/inspector_kotlin.go b/pkg/util/source/inspector_kotlin.go
index b2485c29b..753d0dbbf 100644
--- a/pkg/util/source/inspector_kotlin.go
+++ b/pkg/util/source/inspector_kotlin.go
@@ -37,6 +37,7 @@ func (i KotlinInspector) Extract(source v1.SourceSpec, meta *Metadata) error {
doubleQuotedTo,
doubleQuotedToD,
doubleQuotedToF,
+ doubleQuotedWireTap,
)
meta.FromURIs = append(meta.FromURIs, from...)
diff --git a/pkg/util/source/inspector_kotlin_test.go b/pkg/util/source/inspector_kotlin_test.go
index d94ee7fd9..1b08fe2b3 100644
--- a/pkg/util/source/inspector_kotlin_test.go
+++ b/pkg/util/source/inspector_kotlin_test.go
@@ -37,6 +37,11 @@ from("direct:start")
.to("kamelet:foo/bar?baz=test")
`
+const KotlinWireTapEip = `
+from("direct:start")
+ .wireTap("kamelet:foo/bar?baz=test")
+`
+
func TestKotlinKamelet(t *testing.T) {
tc := []struct {
source string
@@ -50,6 +55,10 @@ func TestKotlinKamelet(t *testing.T) {
source: KotlinKameletEndpoint,
kamelets: []string{"foo/bar"},
},
+ {
+ source: KotlinWireTapEip,
+ kamelets: []string{"foo/bar"},
+ },
}
for i := range tc {