kamelet-flow.groovy

def "kamelet with filter and flow"() {
        setup:
            setFlowMode(YamlDeserializationMode.FLOW)
        
            loadKamelets '''
                apiVersion: camel.apache.org/v1alpha1
                kind: Kamelet
                metadata:
                  name: filter-action
                spec:
                  definition:
                    title: "Filter"
                    description: "Filter based on the body"
                  flow:
                    from:
                      uri: kamelet:source
                      steps:
                      - filter:
                          simple: '${header.foo} == "a"'
                      - to: 
                          uri: "kamelet:sink"    
            '''

            loadRoutes '''
                - from:
                    uri: "direct:start"
                    steps:
                      - kamelet:
                          name: "filter-action"
                      - to: 
                          uri: "mock:result"
            '''

            withMock('mock:result') {
                expectedBodiesReceived '1', '3'
            }

        when:
            context.start()

            withTemplate {
                to('direct:start').withBody('1').withHeader('foo', 'a').send()
                to('direct:start').withBody('2').withHeader('foo', 'b').send()
                to('direct:start').withBody('3').withHeader('foo', 'a').send()
                to('direct:start').withBody('4').withHeader('foo', 'c').send()
            }
        then:
            MockEndpoint.assertIsSatisfied(context)
    }