Repository: camel Updated Branches: refs/heads/camel-2.14.x 1e526e490 -> 865b7ffea
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/388a0928 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/388a0928 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/388a0928 Branch: refs/heads/camel-2.14.x Commit: 388a09288ba36030dd45300325339559bdd25a1b Parents: 1e526e4 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:43:48 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/388a0928/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/388a0928/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); } };
