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) |
getHttpClient, getRequest, getRequest, onLogin, onLogout, setAccessToken, setInstanceUrl, start, stop
public DefaultBulkApiClient(String version, SalesforceSession session, SalesforceHttpClient httpClient) throws SalesforceException
SalesforceException
public void createJob(JobInfo request, Map<String,List<String>> headers, 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, Map<String,List<String>> headers, BulkApiClient.JobInfoResponseCallback callback)
getJob
in interface BulkApiClient
public void closeJob(String jobId, Map<String,List<String>> headers, BulkApiClient.JobInfoResponseCallback callback)
closeJob
in interface BulkApiClient
public void abortJob(String jobId, Map<String,List<String>> headers, BulkApiClient.JobInfoResponseCallback callback)
abortJob
in interface BulkApiClient
public void createBatch(InputStream batchStream, String jobId, ContentType contentTypeEnum, Map<String,List<String>> headers, BulkApiClient.BatchInfoResponseCallback callback)
createBatch
in interface BulkApiClient
public void getBatch(String jobId, String batchId, Map<String,List<String>> headers, BulkApiClient.BatchInfoResponseCallback callback)
getBatch
in interface BulkApiClient
public void getAllBatches(String jobId, Map<String,List<String>> headers, BulkApiClient.BatchInfoListResponseCallback callback)
getAllBatches
in interface BulkApiClient
public void getRequest(String jobId, String batchId, Map<String,List<String>> headers, BulkApiClient.StreamResponseCallback callback)
getRequest
in interface BulkApiClient
public void getResults(String jobId, String batchId, Map<String,List<String>> headers, BulkApiClient.StreamResponseCallback callback)
getResults
in interface BulkApiClient
public void createBatchQuery(String jobId, String soqlQuery, ContentType jobContentType, Map<String,List<String>> headers, BulkApiClient.BatchInfoResponseCallback callback)
createBatchQuery
in interface BulkApiClient
public void getQueryResultIds(String jobId, String batchId, Map<String,List<String>> headers, BulkApiClient.QueryResultIdsCallback callback)
getQueryResultIds
in interface BulkApiClient
public void getQueryResult(String jobId, String batchId, String resultId, Map<String,List<String>> headers, 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