This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/main by this push:
new 61d8a74302e Camel-YAML-DSL: Removed Kamelet Load Source Test for
Groovy (#15883)
61d8a74302e is described below
commit 61d8a74302eae662695530c0019fa0b26ec77b12
Author: Andrea Cosentino <[email protected]>
AuthorDate: Tue Oct 8 12:23:44 2024 +0200
Camel-YAML-DSL: Removed Kamelet Load Source Test for Groovy (#15883)
Signed-off-by: Andrea Cosentino <[email protected]>
---
.../camel/dsl/yaml/KameletLoaderSourcesTest.groovy | 138 ---------------------
1 file changed, 138 deletions(-)
diff --git
a/dsl/camel-yaml-dsl/camel-yaml-dsl/src/test/groovy/org/apache/camel/dsl/yaml/KameletLoaderSourcesTest.groovy
b/dsl/camel-yaml-dsl/camel-yaml-dsl/src/test/groovy/org/apache/camel/dsl/yaml/KameletLoaderSourcesTest.groovy
deleted file mode 100644
index 94b3114d70f..00000000000
---
a/dsl/camel-yaml-dsl/camel-yaml-dsl/src/test/groovy/org/apache/camel/dsl/yaml/KameletLoaderSourcesTest.groovy
+++ /dev/null
@@ -1,138 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.camel.dsl.yaml
-
-import org.apache.camel.Exchange
-import org.apache.camel.Processor
-import org.apache.camel.dsl.yaml.support.YamlTestSupport
-import org.apache.camel.model.LogDefinition
-import org.apache.camel.model.ProcessorDefinition
-import org.apache.camel.model.ToDefinition
-import org.apache.camel.support.DefaultExchange
-import org.junit.jupiter.api.Assertions
-
-class KameletLoaderSourcesTest extends YamlTestSupport {
-
- def "integration sources"() {
- when:
- loadIntegrations('''
- apiVersion: camel.apache.org/v1
- kind: Integration
- metadata:
- name: myapp
- spec:
- flows:
- - from:
- uri: "timer:demo"
- parameters:
- period: 3000
- steps:
- - process:
- ref: myProcessor
- - log: "${body} + ${headers}"
- sources:
- - content: |-
- beans {
- myProcessor = processor {
- it.in.body = 'Hello Camel K!'
- }
- }
- name: myapp.groovy
- ''')
- then:
- context.routeDefinitions.size() == 1
-
- with(context.routeDefinitions[0]) {
- input.endpointUri == 'timer:demo?period=3000'
- input.lineNumber == 8;
- outputs.size() == 2
- with(outputs[0], ProcessorDefinition) {
- ref == 'myProcessor'
- lineNumber == 13;
- }
- with(outputs[1], LogDefinition) {
- message == '${body} + ${headers}'
- lineNumber == 15;
- }
- }
-
- Processor p = context.registry.lookupByNameAndType("myProcessor",
Processor.class)
- Assertions.assertNotNull(p)
-
- Exchange e = new DefaultExchange(context)
- p.process(e)
- e.message.body == 'Hello Camel K!'
- }
-
- def "integration multiple sources"() {
-
- // turn on source locations
- context.sourceLocationEnabled = true
-
- when:
- loadIntegrations('''
- apiVersion: camel.apache.org/v1
- kind: Integration
- metadata:
- name: myapp2
- spec:
- sources:
- - content: |
- // camel-k: language=java
- import org.apache.camel.builder.RouteBuilder;
- public class foo extends RouteBuilder {
- @Override
- public void configure() throws Exception {
- from("timer:demo")
- .process("myProcessor")
- .to("log:info");
- }
- }
- name: foo.java
- - content: |
- beans {
- myProcessor = processor {
- it.in.body = 'Hello Again'
- }
- }
- name: mybean.groovy
- ''')
- then:
- context.routeDefinitions.size() == 1
-
- with(context.routeDefinitions[0]) {
- input.endpointUri == 'timer:demo'
- input.lineNumber == 6;
- outputs.size() == 2
- with(outputs[0], ProcessorDefinition) {
- ref == 'myProcessor'
- lineNumber == 7;
- }
- with(outputs[1], ToDefinition) {
- uri == 'log:info'
- lineNumber == 8;
- }
- }
-
- Processor p = context.registry.lookupByNameAndType("myProcessor",
Processor.class)
- Assertions.assertNotNull(p)
- Exchange e = new DefaultExchange(context)
- p.process(e)
- e.message.body == 'Hello Again'
- }
-
-}
