in salesforce-consumer/src/main/java/org/apache/camel/example/salesforce/SalesforceRouteBuilder.java [24:36]
public void configure() {
from("salesforce:{{salesforce.topic}}")
.unmarshal().json()
.choice()
.when(header("CamelSalesforceEventType").isEqualTo("created"))
.log("New Salesforce contact was created: [ID:${body[Id]}, Name:${body[Name]}, Email:${body[Email]}, Phone: ${body[Phone]}]")
.when(header("CamelSalesforceEventType").isEqualTo("updated"))
.log("A Salesforce contact was updated: [ID:${body[Id]}, Name:${body[Name]}, Email:${body[Email]}, Phone: ${body[Phone]}]")
.when(header("CamelSalesforceEventType").isEqualTo("undeleted"))
.log("A Salesforce contact was undeleted: [ID:${body[Id]}, Name:${body[Name]}, Email:${body[Email]}, Phone: ${body[Phone]}]")
.when(header("CamelSalesforceEventType").isEqualTo("deleted"))
.log("A Salesforce contact was deleted: [ID:${body[Id]}]");
}