Repository: camel Updated Branches: refs/heads/master 2b6bf5f8c -> 781e2c1f2
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/84340b3f Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/84340b3f Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/84340b3f Branch: refs/heads/master Commit: 84340b3f05d39437b725f2f5510f44e862f98b19 Parents: 2b6bf5f 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 09:54:57 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/84340b3f/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/84340b3f/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); } };
