Main.kt

package ninja.util.camel.example

import org.apache.camel.CamelContext
import org.apache.camel.Exchange
import org.apache.camel.ProducerTemplate
import org.apache.camel.builder.ExchangeBuilder
import org.apache.camel.builder.RouteBuilder
import org.apache.camel.impl.DefaultCamelContext

fun CamelContext.addRoute(f : RouteBuilder.() -> Unit) {
    this.addRoutes(object : RouteBuilder() {
        override fun configure() { this.f() }
    })
}

fun ProducerTemplate.sendExchange(f : ExchangeBuilder.() -> Unit) : Exchange {
    val builder = ExchangeBuilder(camelContext)
    builder.f()
    return this.send(builder.build())
}

fun main(args: Array<String>) {
    val ctx = DefaultCamelContext()
    ctx.addRoute {
        from("direct:start")
                .to("log:messages?level=ERROR")
    }

    ctx.start()

    val tmpl = ctx.createProducerTemplate()
    tmpl.setDefaultEndpointUri("direct:start")
    tmpl.sendExchange {
        withBody("This is my first exchange.")
    }
}