CAMEL-8519: Fixed salesforce security listener to replace OAuth header
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/9c1c5512 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/9c1c5512 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/9c1c5512 Branch: refs/heads/camel-2.13.x Commit: 9c1c5512e83e52f45b0e9ac81b88bc29adbdcd8d Parents: 53893e5 Author: Dhiraj Bokde <dhira...@yahoo.com> Authored: Fri Mar 20 09:54:57 2015 -0700 Committer: Dhiraj Bokde <dhira...@yahoo.com> Committed: Fri Mar 20 13:59:44 2015 -0700 ---------------------------------------------------------------------- .../salesforce/internal/client/SalesforceSecurityListener.java | 4 ++-- .../salesforce/internal/streaming/SubscriptionHelper.java | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/9c1c5512/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/client/SalesforceSecurityListener.java ---------------------------------------------------------------------- diff --git a/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/client/SalesforceSecurityListener.java b/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/client/SalesforceSecurityListener.java index 552401c..27d838a 100644 --- a/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/client/SalesforceSecurityListener.java +++ b/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/client/SalesforceSecurityListener.java @@ -103,8 +103,8 @@ public class SalesforceSecurityListener extends HttpEventListenerWrapper { client.setInstanceUrl(session.getInstanceUrl()); client.setAccessToken(exchange); } else { - exchange.addRequestHeader(HttpHeaders.AUTHORIZATION, - "OAuth " + currentToken); + exchange.setRequestHeader(HttpHeaders.AUTHORIZATION, + "OAuth " + currentToken); } // TODO handle a change in Salesforce instanceUrl, right now we retry with the same destination http://git-wip-us.apache.org/repos/asf/camel/blob/9c1c5512/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/streaming/SubscriptionHelper.java ---------------------------------------------------------------------- diff --git a/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/streaming/SubscriptionHelper.java b/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/streaming/SubscriptionHelper.java index 7aaa086..b0ed0d6 100644 --- a/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/streaming/SubscriptionHelper.java +++ b/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/streaming/SubscriptionHelper.java @@ -213,7 +213,7 @@ public class SubscriptionHelper extends ServiceSupport { } // add current security token obtained from session - exchange.addRequestHeader(HttpHeaders.AUTHORIZATION, + exchange.setRequestHeader(HttpHeaders.AUTHORIZATION, "OAuth " + accessToken); } };
