public class SalesforceComponent
extends org.apache.camel.impl.UriEndpointComponent
implements org.apache.camel.spi.EndpointCompleter
SalesforceEndpoint
.Constructor and Description |
---|
SalesforceComponent() |
SalesforceComponent(org.apache.camel.CamelContext context) |
Modifier and Type | Method and Description |
---|---|
List<String> |
completeEndpointPath(org.apache.camel.ComponentConfiguration configuration,
String completionText) |
protected org.apache.camel.Endpoint |
createEndpoint(String uri,
String remaining,
Map<String,Object> parameters) |
protected void |
doStart() |
protected void |
doStop() |
String |
getApexMethod() |
Map<String,Object> |
getApexQueryParams() |
String |
getApexUrl() |
String |
getApiVersion() |
long |
getBackoffIncrement() |
String |
getBatchId() |
Map<String,Class<?>> |
getClassMap() |
String |
getClientId() |
String |
getClientSecret() |
SalesforceEndpointConfig |
getConfig() |
ContentType |
getContentType() |
Long |
getDefaultReplayId() |
PayloadFormat |
getFormat() |
SalesforceHttpClient |
getHttpClient() |
Map<String,Object> |
getHttpClientProperties() |
String |
getHttpProxyAuthUri() |
Set<String> |
getHttpProxyExcludedAddresses() |
String |
getHttpProxyHost() |
Set<String> |
getHttpProxyIncludedAddresses() |
String |
getHttpProxyPassword() |
Integer |
getHttpProxyPort() |
String |
getHttpProxyRealm() |
String |
getHttpProxyUsername() |
Boolean |
getIncludeDetails() |
Map<String,Long> |
getInitialReplayIdMap() |
String |
getInstanceId() |
String |
getInstanceUrl(String instanceUrl) |
String |
getJobId() |
SalesforceLoginConfig |
getLoginConfig() |
String |
getLoginUrl() |
long |
getMaxBackoff() |
NotifyForFieldsEnum |
getNotifyForFields() |
Boolean |
getNotifyForOperationCreate() |
Boolean |
getNotifyForOperationDelete() |
NotifyForOperationsEnum |
getNotifyForOperations() |
Boolean |
getNotifyForOperationUndelete() |
Boolean |
getNotifyForOperationUpdate() |
org.codehaus.jackson.map.ObjectMapper |
getObjectMapper() |
String[] |
getPackages() |
String |
getPassword() |
String |
getReportId() |
ReportMetadata |
getReportMetadata() |
String |
getResultId() |
SalesforceSession |
getSession() |
String |
getSObjectBlobFieldName() |
String |
getSObjectClass() |
String |
getSObjectFields() |
String |
getSObjectId() |
String |
getSObjectIdName() |
String |
getSObjectIdValue() |
String |
getSObjectName() |
String |
getSObjectQuery() |
String |
getSObjectSearch() |
org.apache.camel.util.jsse.SSLContextParameters |
getSslContextParameters() |
SubscriptionHelper |
getSubscriptionHelper() |
String |
getUserName() |
boolean |
isHttpProxySecure() |
boolean |
isHttpProxySocks4() |
boolean |
isHttpProxyUseDigestAuth() |
boolean |
isLazyLogin() |
boolean |
isUpdateTopic() |
void |
setApexMethod(String apexMethod)
APEX method name
|
void |
setApexQueryParams(Map<String,Object> apexQueryParams)
Query params for APEX method
|
void |
setApexUrl(String apexUrl)
APEX method URL
|
void |
setApiVersion(String apiVersion)
Salesforce API version, defaults to SalesforceEndpointConfig.DEFAULT_VERSION
|
void |
setBackoffIncrement(long backoffIncrement)
Backoff interval increment for Streaming connection restart attempts for failures beyond CometD auto-reconnect.
|
void |
setBatchId(String batchId)
Bulk API Batch ID
|
void |
setClientId(String clientId)
Salesforce connected application Consumer Key
|
void |
setClientSecret(String clientSecret)
Salesforce connected application Consumer Secret
|
void |
setConfig(SalesforceEndpointConfig config)
To use the shared SalesforceLoginConfig as configuration
|
void |
setContentType(ContentType contentType)
Bulk API content type, one of XML, CSV, ZIP_XML, ZIP_CSV
|
void |
setDefaultReplayId(Long defaultReplayId)
Default replayId setting if no value is found in
#initialReplayIdMap |
void |
setFormat(PayloadFormat format)
Payload format to use for Salesforce API calls, either JSON or XML, defaults to JSON
|
void |
setHttpClient(SalesforceHttpClient httpClient)
Custom Jetty Http Client to use to connect to Salesforce.
|
void |
setHttpClientProperties(Map<String,Object> httpClientProperties)
Used for configuring HTTP client properties as key/value pairs
|
void |
setHttpProxyAuthUri(String httpProxyAuthUri)
HTTP proxy authentication URI
|
void |
setHttpProxyExcludedAddresses(Set<String> httpProxyExcludedAddresses)
HTTP proxy excluded addresses
|
void |
setHttpProxyHost(String httpProxyHost)
To configure HTTP proxy host
|
void |
setHttpProxyIncludedAddresses(Set<String> httpProxyIncludedAddresses)
HTTP proxy included addresses
|
void |
setHttpProxyPassword(String httpProxyPassword)
To configure HTTP proxy password
|
void |
setHttpProxyPort(Integer httpProxyPort)
To configure HTTP proxy port
|
void |
setHttpProxyRealm(String httpProxyRealm)
HTTP proxy authentication realm
|
void |
setHttpProxyUseDigestAuth(boolean httpProxyUseDigestAuth)
Use HTTP proxy Digest authentication, false by default
|
void |
setHttpProxyUsername(String httpProxyUsername)
To configure HTTP proxy username
|
void |
setIncludeDetails(Boolean includeDetails)
Include details in Salesforce1 Analytics report, defaults to false.
|
void |
setInitialReplayIdMap(Map<String,Long> initialReplayIdMap)
Replay IDs to start from per channel name.
|
void |
setInstanceId(String instanceId)
Salesforce1 Analytics report execution instance ID
|
void |
setInstanceUrl(String instanceUrl)
URL of the Salesforce instance used after authantication, by default received from
Salesforce on successful authentication
|
void |
setIsHttpProxySecure(boolean isHttpProxySecure)
Enable for TLS connections, true by default
|
void |
setIsHttpProxySocks4(boolean isHttpProxySocks4)
Enable for Socks4 proxy, false by default
|
void |
setJobId(String jobId)
Bulk API Job ID
|
void |
setLazyLogin(boolean lazyLogin)
Flag to enable/disable lazy OAuth, default is false.
|
void |
setLoginConfig(SalesforceLoginConfig loginConfig)
To use the shared SalesforceLoginConfig as login configuration
|
void |
setLoginUrl(String loginUrl)
Salesforce login URL, defaults to https://login.salesforce.com
|
void |
setMaxBackoff(long maxBackoff)
Maximum backoff interval for Streaming connection restart attempts for failures beyond CometD auto-reconnect.
|
void |
setNotifyForFields(NotifyForFieldsEnum notifyForFields)
Notify for fields, options are ALL, REFERENCED, SELECT, WHERE
|
void |
setNotifyForOperationCreate(Boolean notifyForOperationCreate)
Notify for create operation, defaults to false (API version >= 29.0)
|
void |
setNotifyForOperationDelete(Boolean notifyForOperationDelete)
Notify for delete operation, defaults to false (API version >= 29.0)
|
void |
setNotifyForOperations(NotifyForOperationsEnum notifyForOperations)
Notify for operations, options are ALL, CREATE, EXTENDED, UPDATE (API version < 29.0)
|
void |
setNotifyForOperationUndelete(Boolean notifyForOperationUndelete)
Notify for un-delete operation, defaults to false (API version >= 29.0)
|
void |
setNotifyForOperationUpdate(Boolean notifyForOperationUpdate)
Notify for update operation, defaults to false (API version >= 29.0)
|
void |
setObjectMapper(org.codehaus.jackson.map.ObjectMapper objectMapper)
Custom Jackson ObjectMapper to use when serializing/deserializing Salesforce objects.
|
void |
setPackages(String packages)
Package names to scan for DTO classes (multiple packages can be separated by comma).
|
void |
setPackages(String[] packages)
Package names to scan for DTO classes (multiple packages can be separated by comma).
|
void |
setPassword(String password)
Salesforce account password
|
void |
setReportId(String reportId)
Salesforce1 Analytics report Id
|
void |
setReportMetadata(ReportMetadata reportMetadata)
Salesforce1 Analytics report metadata for filtering
|
void |
setResultId(String resultId)
Bulk API Result ID
|
void |
setSObjectBlobFieldName(String sObjectBlobFieldName)
SObject blob field name
|
void |
setSObjectClass(String sObjectClass)
Fully qualified SObject class name, usually generated using camel-salesforce-maven-plugin
|
void |
setSObjectFields(String sObjectFields)
SObject fields to retrieve
|
void |
setSObjectId(String sObjectId)
SObject ID if required by API
|
void |
setSObjectIdName(String sObjectIdName)
SObject external ID field name
|
void |
setSObjectIdValue(String sObjectIdValue)
SObject external ID field value
|
void |
setSObjectName(String sObjectName)
SObject name if required or supported by API
|
void |
setSObjectQuery(String sObjectQuery)
Salesforce SOQL query string
|
void |
setSObjectSearch(String sObjectSearch)
Salesforce SOSL search string
|
void |
setSslContextParameters(org.apache.camel.util.jsse.SSLContextParameters sslContextParameters)
To configure security using SSLContextParameters
|
void |
setUpdateTopic(boolean updateTopic)
Whether to update an existing Push Topic when using the Streaming API, defaults to false
|
void |
setUserName(String userName)
Salesforce account user name
|
createComponentConfiguration, createParameterConfigurationMap, getEndpointClass, getParameterConfigurationMap, populateParameterConfigurationMap, setEndpointClass
afterConfiguration, createConfiguration, createEndpoint, getAndRemoveOrResolveReferenceParameter, getAndRemoveOrResolveReferenceParameter, getAndRemoveParameter, getAndRemoveParameter, getCamelContext, ifStartsWithReturnRemainder, preProcessUri, resolveAndRemoveReferenceListParameter, resolveAndRemoveReferenceListParameter, resolveAndRemoveReferenceParameter, resolveAndRemoveReferenceParameter, setCamelContext, setProperties, setProperties, useIntrospectionOnEndpoint, useRawUri, validateParameters, validateURI
public SalesforceComponent()
public SalesforceComponent(org.apache.camel.CamelContext context)
protected org.apache.camel.Endpoint createEndpoint(String uri, String remaining, Map<String,Object> parameters) throws Exception
createEndpoint
in class org.apache.camel.impl.DefaultComponent
Exception
protected void doStart() throws Exception
doStart
in class org.apache.camel.impl.DefaultComponent
Exception
protected void doStop() throws Exception
doStop
in class org.apache.camel.impl.DefaultComponent
Exception
public SubscriptionHelper getSubscriptionHelper() throws Exception
Exception
public List<String> completeEndpointPath(org.apache.camel.ComponentConfiguration configuration, String completionText)
completeEndpointPath
in interface org.apache.camel.spi.EndpointCompleter
public SalesforceLoginConfig getLoginConfig()
public void setLoginConfig(SalesforceLoginConfig loginConfig)
public SalesforceEndpointConfig getConfig()
public void setConfig(SalesforceEndpointConfig config)
public void setHttpClientProperties(Map<String,Object> httpClientProperties)
public org.apache.camel.util.jsse.SSLContextParameters getSslContextParameters()
public void setSslContextParameters(org.apache.camel.util.jsse.SSLContextParameters sslContextParameters)
public String getHttpProxyHost()
public void setHttpProxyHost(String httpProxyHost)
public Integer getHttpProxyPort()
public void setHttpProxyPort(Integer httpProxyPort)
public String getHttpProxyUsername()
public void setHttpProxyUsername(String httpProxyUsername)
public String getHttpProxyPassword()
public void setHttpProxyPassword(String httpProxyPassword)
public boolean isHttpProxySocks4()
public void setIsHttpProxySocks4(boolean isHttpProxySocks4)
public boolean isHttpProxySecure()
public void setIsHttpProxySecure(boolean isHttpProxySecure)
public void setHttpProxyIncludedAddresses(Set<String> httpProxyIncludedAddresses)
public void setHttpProxyExcludedAddresses(Set<String> httpProxyExcludedAddresses)
public String getHttpProxyAuthUri()
public void setHttpProxyAuthUri(String httpProxyAuthUri)
public String getHttpProxyRealm()
public void setHttpProxyRealm(String httpProxyRealm)
public boolean isHttpProxyUseDigestAuth()
public void setHttpProxyUseDigestAuth(boolean httpProxyUseDigestAuth)
public String[] getPackages()
public void setPackages(String[] packages)
public void setPackages(String packages)
public SalesforceSession getSession()
public void setInstanceUrl(String instanceUrl)
instanceUrl
- public String getLoginUrl()
public void setLoginUrl(String loginUrl)
loginUrl
- public String getClientId()
public void setClientId(String clientId)
clientId
- public String getClientSecret()
public void setClientSecret(String clientSecret)
clientSecret
- public String getUserName()
public void setUserName(String userName)
userName
- public String getPassword()
public void setPassword(String password)
password
- public boolean isLazyLogin()
public void setLazyLogin(boolean lazyLogin)
lazyLogin
- public PayloadFormat getFormat()
public void setFormat(PayloadFormat format)
format
- public String getApiVersion()
public void setApiVersion(String apiVersion)
apiVersion
- public String getSObjectName()
public void setSObjectName(String sObjectName)
sObjectName
- public String getSObjectId()
public void setSObjectId(String sObjectId)
sObjectId
- public String getSObjectFields()
public void setSObjectFields(String sObjectFields)
sObjectFields
- public String getSObjectIdName()
public void setSObjectIdName(String sObjectIdName)
sObjectIdName
- public String getSObjectIdValue()
public void setSObjectIdValue(String sObjectIdValue)
sObjectIdValue
- public String getSObjectBlobFieldName()
public void setSObjectBlobFieldName(String sObjectBlobFieldName)
sObjectBlobFieldName
- public String getSObjectClass()
public void setSObjectClass(String sObjectClass)
sObjectClass
- public String getSObjectQuery()
public void setSObjectQuery(String sObjectQuery)
sObjectQuery
- public String getSObjectSearch()
public void setSObjectSearch(String sObjectSearch)
sObjectSearch
- public String getApexMethod()
public void setApexMethod(String apexMethod)
apexMethod
- public String getApexUrl()
public void setApexUrl(String apexUrl)
apexUrl
- public void setApexQueryParams(Map<String,Object> apexQueryParams)
apexQueryParams
- public ContentType getContentType()
public void setContentType(ContentType contentType)
contentType
- public String getJobId()
public void setJobId(String jobId)
jobId
- public String getBatchId()
public void setBatchId(String batchId)
batchId
- public String getResultId()
public void setResultId(String resultId)
resultId
- public boolean isUpdateTopic()
public void setUpdateTopic(boolean updateTopic)
updateTopic
- public NotifyForFieldsEnum getNotifyForFields()
public void setNotifyForFields(NotifyForFieldsEnum notifyForFields)
notifyForFields
- public NotifyForOperationsEnum getNotifyForOperations()
public void setNotifyForOperations(NotifyForOperationsEnum notifyForOperations)
notifyForOperations
- public Boolean getNotifyForOperationCreate()
public void setNotifyForOperationCreate(Boolean notifyForOperationCreate)
notifyForOperationCreate
- public Boolean getNotifyForOperationUpdate()
public void setNotifyForOperationUpdate(Boolean notifyForOperationUpdate)
notifyForOperationUpdate
- public Boolean getNotifyForOperationDelete()
public void setNotifyForOperationDelete(Boolean notifyForOperationDelete)
notifyForOperationDelete
- public Boolean getNotifyForOperationUndelete()
public void setNotifyForOperationUndelete(Boolean notifyForOperationUndelete)
notifyForOperationUndelete
- public String getReportId()
public void setReportId(String reportId)
reportId
- public Boolean getIncludeDetails()
public void setIncludeDetails(Boolean includeDetails)
includeDetails
- public ReportMetadata getReportMetadata()
public void setReportMetadata(ReportMetadata reportMetadata)
reportMetadata
- public String getInstanceId()
public void setInstanceId(String instanceId)
instanceId
- public void setHttpClient(SalesforceHttpClient httpClient)
httpClient
- public SalesforceHttpClient getHttpClient()
public org.codehaus.jackson.map.ObjectMapper getObjectMapper()
public void setObjectMapper(org.codehaus.jackson.map.ObjectMapper objectMapper)
objectMapper
- public Long getDefaultReplayId()
public void setDefaultReplayId(Long defaultReplayId)
#initialReplayIdMap
defaultReplayId
- public void setInitialReplayIdMap(Map<String,Long> initialReplayIdMap)
initialReplayIdMap
- public long getBackoffIncrement()
public void setBackoffIncrement(long backoffIncrement)
backoffIncrement
- public long getMaxBackoff()
public void setMaxBackoff(long maxBackoff)
maxBackoff
- Apache Camel