Allow flexible formatting from URI: JSON | XML

Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/0fb326d5
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/0fb326d5
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/0fb326d5

Branch: refs/heads/kube-lb
Commit: 0fb326d554924b8a2e0cb88a0b395abbee835c28
Parents: 4eb0df9
Author: Sergio Martinez <checo...@gmail.com>
Authored: Wed May 11 19:51:20 2016 -0700
Committer: Claus Ibsen <davscl...@apache.org>
Committed: Mon May 16 09:59:33 2016 +0200

----------------------------------------------------------------------
 .../org/apache/camel/component/salesforce/SalesforceConsumer.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/camel/blob/0fb326d5/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/SalesforceConsumer.java
----------------------------------------------------------------------
diff --git 
a/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/SalesforceConsumer.java
 
b/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/SalesforceConsumer.java
index ac44d5a..e6434a5 100644
--- 
a/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/SalesforceConsumer.java
+++ 
b/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/SalesforceConsumer.java
@@ -103,7 +103,7 @@ public class SalesforceConsumer extends DefaultConsumer {
             // create REST client for PushTopic operations
             SalesforceComponent component = endpoint.getComponent();
             RestClient restClient = new 
DefaultRestClient(component.getConfig().getHttpClient(),
-                    endpoint.getConfiguration().getApiVersion(), 
PayloadFormat.JSON, component.getSession());
+                    endpoint.getConfiguration().getApiVersion(), 
endpoint.getConfiguration().getFormat(), component.getSession());
             // don't forget to start the client
             ServiceHelper.startService(restClient);
 

Reply via email to