public class DefaultBulkApiClient extends AbstractClientBase implements BulkApiClient
AbstractClientBase.ClientResponseCallback
BulkApiClient.BatchInfoListResponseCallback, BulkApiClient.BatchInfoResponseCallback, BulkApiClient.JobInfoResponseCallback, BulkApiClient.QueryResultIdsCallback, BulkApiClient.StreamResponseCallback
accessToken, APPLICATION_JSON_UTF8, APPLICATION_XML_UTF8, httpClient, instanceUrl, log, session, version
Constructor and Description |
---|
DefaultBulkApiClient(String version,
SalesforceSession session,
SalesforceHttpClient httpClient) |
getRequest, getRequest, onLogin, onLogout, setAccessToken, setInstanceUrl, start, stop
public DefaultBulkApiClient(String version, SalesforceSession session, SalesforceHttpClient httpClient) throws SalesforceException
SalesforceException
public void createJob(JobInfo request, BulkApiClient.JobInfoResponseCallback callback)
BulkApiClient
createJob
in interface BulkApiClient
request
- JobInfo
with required fieldscallback
- BulkApiClient.JobInfoResponseCallback
to be invoked on response or errorpublic void getJob(String jobId, BulkApiClient.JobInfoResponseCallback callback)
getJob
in interface BulkApiClient
public void closeJob(String jobId, BulkApiClient.JobInfoResponseCallback callback)
closeJob
in interface BulkApiClient
public void abortJob(String jobId, BulkApiClient.JobInfoResponseCallback callback)
abortJob
in interface BulkApiClient
public void createBatch(InputStream batchStream, String jobId, ContentType contentTypeEnum, BulkApiClient.BatchInfoResponseCallback callback)
createBatch
in interface BulkApiClient
public void getBatch(String jobId, String batchId, BulkApiClient.BatchInfoResponseCallback callback)
getBatch
in interface BulkApiClient
public void getAllBatches(String jobId, BulkApiClient.BatchInfoListResponseCallback callback)
getAllBatches
in interface BulkApiClient
public void getRequest(String jobId, String batchId, BulkApiClient.StreamResponseCallback callback)
getRequest
in interface BulkApiClient
public void getResults(String jobId, String batchId, BulkApiClient.StreamResponseCallback callback)
getResults
in interface BulkApiClient
public void createBatchQuery(String jobId, String soqlQuery, ContentType jobContentType, BulkApiClient.BatchInfoResponseCallback callback)
createBatchQuery
in interface BulkApiClient
public void getQueryResultIds(String jobId, String batchId, BulkApiClient.QueryResultIdsCallback callback)
getQueryResultIds
in interface BulkApiClient
public void getQueryResult(String jobId, String batchId, String resultId, BulkApiClient.StreamResponseCallback callback)
getQueryResult
in interface BulkApiClient
protected void setAccessToken(org.eclipse.jetty.client.api.Request request)
setAccessToken
in class AbstractClientBase
protected void doHttpRequest(org.eclipse.jetty.client.api.Request request, AbstractClientBase.ClientResponseCallback callback)
doHttpRequest
in class AbstractClientBase
protected SalesforceException createRestException(org.eclipse.jetty.client.api.Response response, InputStream responseContent)
createRestException
in class AbstractClientBase
Apache Camel