com.liferay.petra.salesforce.client.bulk

Class SalesforceBulkClientImpl

java.lang.Object

com.liferay.petra.salesforce.client.BaseSalesforceClientImpl

com.liferay.petra.salesforce.client.bulk.SalesforceBulkClientImpl

All Implemented Interfaces:

SalesforceBulkClient, SalesforceClient

public class SalesforceBulkClientImpl
extends BaseSalesforceClientImpl
implements SalesforceBulkClient

Constructor Summary

Constructors

Constructor and Description
SalesforceBulkClientImpl()

Method Summary

Modifier and Type	Method and Description
JobInfo	abortJob(java.lang.String jobInfoId, int retryCount)
JobInfo	closeJob(java.lang.String jobInfoId, int retryCount)
BatchInfo	createBatchFromStream(JobInfo jobInfo, java.io.InputStream inputStream, int retryCount)
JobInfo	createJob(JobInfo jobInfo, int retryCount)
BatchInfo	getBatchInfo(java.lang.String jobInfoId, java.lang.String batchInfoId, int retryCount)
QueryResultList	getQueryResultList(java.lang.String jobInfoId, java.lang.String batchInfoId, int retryCount)
java.io.InputStream	getQueryResultStream(java.lang.String jobInfoId, java.lang.String batchInfoId, java.lang.String queryResultId, int retryCount)

Methods inherited from class com.liferay.petra.salesforce.client.BaseSalesforceClientImpl

afterPropertiesSet, getAuthEndpoint, getConnectionTimeout, getConnectorConfig, getPartnerConnection, getPassword, getReadTimeout, getRetryCount, getRetryCount, getServiceEndpoint, getSessionId, getUserName, isDebugEnabled, setAuthEndpoint, setConnectionTimeout, setDebugEnabled, setPassword, setReadTimeout, setServiceEndpoint, setSessionId, setUserName

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.liferay.petra.salesforce.client.SalesforceClient

getAuthEndpoint, getConnectionTimeout, getConnectorConfig, getPassword, getReadTimeout, getServiceEndpoint, getSessionId, getUserName, isDebugEnabled, setAuthEndpoint, setConnectionTimeout, setDebugEnabled, setPassword, setReadTimeout, setServiceEndpoint, setSessionId, setUserName

Constructor Detail

SalesforceBulkClientImpl

public SalesforceBulkClientImpl()

Method Detail

abortJob

public JobInfo abortJob(java.lang.String jobInfoId,
                        int retryCount)
                 throws AsyncApiException,
                        ConnectionException

Specified by:

abortJob in interface SalesforceBulkClient

Throws:

AsyncApiException

ConnectionException

closeJob

public JobInfo closeJob(java.lang.String jobInfoId,
                        int retryCount)
                 throws AsyncApiException,
                        ConnectionException

Specified by:

closeJob in interface SalesforceBulkClient

Throws:

AsyncApiException

ConnectionException

createBatchFromStream

public BatchInfo createBatchFromStream(JobInfo jobInfo,
                                       java.io.InputStream inputStream,
                                       int retryCount)
                                throws AsyncApiException,
                                       ConnectionException

Specified by:

createBatchFromStream in interface SalesforceBulkClient

Throws:

AsyncApiException

ConnectionException

createJob

public JobInfo createJob(JobInfo jobInfo,
                         int retryCount)
                  throws AsyncApiException,
                         ConnectionException

Specified by:

createJob in interface SalesforceBulkClient

Throws:

AsyncApiException

ConnectionException

getBatchInfo

public BatchInfo getBatchInfo(java.lang.String jobInfoId,
                              java.lang.String batchInfoId,
                              int retryCount)
                       throws AsyncApiException,
                              ConnectionException

Specified by:

getBatchInfo in interface SalesforceBulkClient

Throws:

AsyncApiException

ConnectionException

getQueryResultList

public QueryResultList getQueryResultList(java.lang.String jobInfoId,
                                          java.lang.String batchInfoId,
                                          int retryCount)
                                   throws AsyncApiException,
                                          ConnectionException

Specified by:

getQueryResultList in interface SalesforceBulkClient

Throws:

AsyncApiException

ConnectionException

getQueryResultStream

public java.io.InputStream getQueryResultStream(java.lang.String jobInfoId,
                                                java.lang.String batchInfoId,
                                                java.lang.String queryResultId,
                                                int retryCount)
                                         throws AsyncApiException,
                                                ConnectionException

Specified by:

getQueryResultStream in interface SalesforceBulkClient

Throws:

AsyncApiException

ConnectionException