org.apache.camel.component.salesforce.internal.client
Interface BulkApiClient

All Known Implementing Classes:

DefaultBulkApiClient

public interface BulkApiClient

Client interface for Salesforce Bulk API

Nested Class Summary

static interface	BulkApiClient.BatchInfoListResponseCallback
static interface	BulkApiClient.BatchInfoResponseCallback
static interface	BulkApiClient.JobInfoResponseCallback
static interface	BulkApiClient.QueryResultIdsCallback
static interface	BulkApiClient.StreamResponseCallback

Method Summary

void	abortJob(String jobId, BulkApiClient.JobInfoResponseCallback callback)
void	closeJob(String jobId, BulkApiClient.JobInfoResponseCallback callback)
void	createBatch(InputStream batchStream, String jobId, ContentType contentTypeEnum, BulkApiClient.BatchInfoResponseCallback callback)
void	createBatchQuery(String jobId, String soqlQuery, ContentType jobContentType, BulkApiClient.BatchInfoResponseCallback callback)
void	createJob(JobInfo jobInfo, BulkApiClient.JobInfoResponseCallback callback) Creates a Bulk Job
void	getAllBatches(String jobId, BulkApiClient.BatchInfoListResponseCallback callback)
void	getBatch(String jobId, String batchId, BulkApiClient.BatchInfoResponseCallback callback)
void	getJob(String jobId, BulkApiClient.JobInfoResponseCallback callback)
void	getQueryResult(String jobId, String batchId, String resultId, BulkApiClient.StreamResponseCallback callback)
void	getQueryResultIds(String jobId, String batchId, BulkApiClient.QueryResultIdsCallback callback)
void	getRequest(String jobId, String batchId, BulkApiClient.StreamResponseCallback callback)
void	getResults(String jobId, String batchId, BulkApiClient.StreamResponseCallback callback)

Method Detail

createJob

void createJob(JobInfo jobInfo,
               BulkApiClient.JobInfoResponseCallback callback)

Creates a Bulk Job

Parameters:

jobInfo - JobInfo with required fields

callback - BulkApiClient.JobInfoResponseCallback to be invoked on response or error

getJob

void getJob(String jobId,
            BulkApiClient.JobInfoResponseCallback callback)

closeJob

void closeJob(String jobId,
              BulkApiClient.JobInfoResponseCallback callback)

abortJob

void abortJob(String jobId,
              BulkApiClient.JobInfoResponseCallback callback)

createBatch

void createBatch(InputStream batchStream,
                 String jobId,
                 ContentType contentTypeEnum,
                 BulkApiClient.BatchInfoResponseCallback callback)

getBatch

void getBatch(String jobId,
              String batchId,
              BulkApiClient.BatchInfoResponseCallback callback)

getAllBatches

void getAllBatches(String jobId,
                   BulkApiClient.BatchInfoListResponseCallback callback)

getRequest

void getRequest(String jobId,
                String batchId,
                BulkApiClient.StreamResponseCallback callback)

getResults

void getResults(String jobId,
                String batchId,
                BulkApiClient.StreamResponseCallback callback)

createBatchQuery

void createBatchQuery(String jobId,
                      String soqlQuery,
                      ContentType jobContentType,
                      BulkApiClient.BatchInfoResponseCallback callback)

getQueryResultIds

void getQueryResultIds(String jobId,
                       String batchId,
                       BulkApiClient.QueryResultIdsCallback callback)

getQueryResult

void getQueryResult(String jobId,
                    String batchId,
                    String resultId,
                    BulkApiClient.StreamResponseCallback callback)