<sfdc:config name="Salesforce" username="${sfdc.user}" password="${sfdc.password}" securityToken="${sfdc.token}" doc:name="Salesforce"/>
<flow name="salesforce-exampleFlow">
    <sfdc:subscribe-topic config-ref="Salesforce" doc:name="Salesforce (Streaming)" topic="/ContactTopic"/>
    <logger message="Received Event : #[payload.Id] - #[payload.FirstName] #[payload.LastName]" level="INFO" doc:name="Logger"/>
    <sfdc:query-single config-ref="Salesforce" query="dsql:SELECT AccountId,Email,FirstName,HomePhone,Id,LastName FROM Contact WHERE Id = '#[payload.Id]'" doc:name="Salesforce"/>
    <json:object-to-json-transformer doc:name="Object to JSON"/>
    <logger message="#[payload]" level="INFO" doc:name="Logger"/>
</flow>