// camel-k: dependency=camel-jackson
// camel-k: language=java

import org.apache.camel.builder.RouteBuilder;

public class SalesforceConsumer extends RouteBuilder {
    public void configure() {
        from("knative:channel/salesforce")
            .unmarshal().json()
            .log("New Salesforce contact was created: [ID:${body[Id]}, Name:${body[Name]}, Email:${body[Email]}, Phone: ${body[Phone]}]")
            .marshal().json(); // To avoid a WARN - https://github.com/apache/camel-k-runtime/issues/390
    }
}