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
com.sforce.async.JobInfo	abortJob(java.lang.String jobInfoId, int retryCount)
com.sforce.async.JobInfo	closeJob(java.lang.String jobInfoId, int retryCount)
com.sforce.async.BatchInfo	createBatchFromStream(com.sforce.async.JobInfo jobInfo, java.io.InputStream inputStream, int retryCount)
com.sforce.async.JobInfo	createJob(com.sforce.async.JobInfo jobInfo, int retryCount)
com.sforce.async.BatchInfo	getBatchInfo(java.lang.String jobInfoId, java.lang.String batchInfoId, int retryCount)
com.sforce.async.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 com.sforce.async.JobInfo abortJob(java.lang.String jobInfoId,
                                         int retryCount)
                                  throws com.sforce.async.AsyncApiException,
                                         com.sforce.ws.ConnectionException

Specified by:

abortJob in interface SalesforceBulkClient

Throws:

com.sforce.async.AsyncApiException

com.sforce.ws.ConnectionException

closeJob

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

Specified by:

closeJob in interface SalesforceBulkClient

Throws:

com.sforce.async.AsyncApiException

com.sforce.ws.ConnectionException

createBatchFromStream

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

Specified by:

createBatchFromStream in interface SalesforceBulkClient

Throws:

com.sforce.async.AsyncApiException

com.sforce.ws.ConnectionException

createJob

public com.sforce.async.JobInfo createJob(com.sforce.async.JobInfo jobInfo,
                                          int retryCount)
                                   throws com.sforce.async.AsyncApiException,
                                          com.sforce.ws.ConnectionException

Specified by:

createJob in interface SalesforceBulkClient

Throws:

com.sforce.async.AsyncApiException

com.sforce.ws.ConnectionException

getBatchInfo

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

Specified by:

getBatchInfo in interface SalesforceBulkClient

Throws:

com.sforce.async.AsyncApiException

com.sforce.ws.ConnectionException

getQueryResultList

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

Specified by:

getQueryResultList in interface SalesforceBulkClient

Throws:

com.sforce.async.AsyncApiException

com.sforce.ws.ConnectionException

getQueryResultStream

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

Specified by:

getQueryResultStream in interface SalesforceBulkClient

Throws:

com.sforce.async.AsyncApiException

com.sforce.ws.ConnectionException