public class DefaultRestClient extends AbstractClientBase implements RestClient
AbstractClientBase.ClientResponseCallback
RestClient.ResponseCallback
Modifier and Type | Field and Description |
---|---|
protected PayloadFormat |
format |
accessToken, APPLICATION_JSON_UTF8, APPLICATION_XML_UTF8, httpClient, instanceUrl, log, session, version
Constructor and Description |
---|
DefaultRestClient(SalesforceHttpClient httpClient,
String version,
PayloadFormat format,
SalesforceSession session) |
Modifier and Type | Method and Description |
---|---|
void |
apexCall(String httpMethod,
String apexUrl,
Map<String,Object> queryParams,
InputStream requestDto,
RestClient.ResponseCallback callback)
Executes a user defined APEX REST API call.
|
protected SalesforceException |
createRestException(org.eclipse.jetty.client.api.Response response,
InputStream responseContent) |
void |
createSObject(String sObjectName,
InputStream sObject,
RestClient.ResponseCallback callback)
Creates a record for the specified object.
|
void |
deleteSObject(String sObjectName,
String id,
RestClient.ResponseCallback callback)
Deletes a record for the specified object ID.
|
void |
deleteSObjectWithId(String sObjectName,
String fieldName,
String fieldValue,
RestClient.ResponseCallback callback)
Deletes a record based on the value of a specified external ID field.
|
protected void |
doHttpRequest(org.eclipse.jetty.client.api.Request request,
AbstractClientBase.ClientResponseCallback callback) |
void |
getBasicInfo(String sObjectName,
RestClient.ResponseCallback callback)
Describes the individual metadata for the specified object.
|
void |
getBlobField(String sObjectName,
String id,
String blobFieldName,
RestClient.ResponseCallback callback)
Retrieves the specified blob field from an individual record.
|
void |
getDescription(String sObjectName,
RestClient.ResponseCallback callback)
Completely describes the individual metadata at all levels for the specified object.
|
void |
getGlobalObjects(RestClient.ResponseCallback callback)
Lists the available objects and their metadata for your organization's data.
|
void |
getResources(RestClient.ResponseCallback callback)
Lists available resources for the specified API version, including resource name and URI.
|
void |
getSObject(String sObjectName,
String id,
String[] fields,
RestClient.ResponseCallback callback)
Retrieves a record for the specified object ID.
|
void |
getSObjectWithId(String sObjectName,
String fieldName,
String fieldValue,
RestClient.ResponseCallback callback)
Retrieves a record for the specified external ID.
|
void |
getVersions(RestClient.ResponseCallback callback)
Lists summary information about each API version currently available,
including the version, label, and a link to each version's root.
|
void |
query(String soqlQuery,
RestClient.ResponseCallback callback)
Executes the specified SOQL query.
|
void |
queryAll(String soqlQuery,
RestClient.ResponseCallback callback)
Executes the specified SOQL query including deleted records.
|
void |
queryMore(String nextRecordsUrl,
RestClient.ResponseCallback callback)
Get SOQL query results using nextRecordsUrl.
|
void |
search(String soslQuery,
RestClient.ResponseCallback callback)
Executes the specified SOSL search.
|
protected void |
setAccessToken(org.eclipse.jetty.client.api.Request request) |
void |
updateSObject(String sObjectName,
String id,
InputStream sObject,
RestClient.ResponseCallback callback)
Updates a record for the specified object ID.
|
void |
upsertSObject(String sObjectName,
String fieldName,
String fieldValue,
InputStream sObject,
RestClient.ResponseCallback callback)
Creates or updates a record based on the value of a specified external ID field.
|
getRequest, getRequest, onLogin, onLogout, setAccessToken, setInstanceUrl, start, stop
protected PayloadFormat format
public DefaultRestClient(SalesforceHttpClient httpClient, String version, PayloadFormat format, SalesforceSession session) throws SalesforceException
SalesforceException
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
public void getVersions(RestClient.ResponseCallback callback)
RestClient
getVersions
in interface RestClient
callback
- RestClient.ResponseCallback
to handle response or exceptionpublic void getResources(RestClient.ResponseCallback callback)
RestClient
getResources
in interface RestClient
callback
- RestClient.ResponseCallback
to handle response or exceptionpublic void getGlobalObjects(RestClient.ResponseCallback callback)
RestClient
getGlobalObjects
in interface RestClient
callback
- RestClient.ResponseCallback
to handle response or exceptionpublic void getBasicInfo(String sObjectName, RestClient.ResponseCallback callback)
RestClient
getBasicInfo
in interface RestClient
sObjectName
- specified object namecallback
- RestClient.ResponseCallback
to handle response or exceptionpublic void getDescription(String sObjectName, RestClient.ResponseCallback callback)
RestClient
getDescription
in interface RestClient
sObjectName
- specified object namecallback
- RestClient.ResponseCallback
to handle response or exceptionpublic void getSObject(String sObjectName, String id, String[] fields, RestClient.ResponseCallback callback)
RestClient
getSObject
in interface RestClient
sObjectName
- specified object nameid
- object idcallback
- RestClient.ResponseCallback
to handle response or exceptionpublic void createSObject(String sObjectName, InputStream sObject, RestClient.ResponseCallback callback)
RestClient
createSObject
in interface RestClient
sObjectName
- specified object namesObject
- request entitycallback
- RestClient.ResponseCallback
to handle response or exceptionpublic void updateSObject(String sObjectName, String id, InputStream sObject, RestClient.ResponseCallback callback)
RestClient
updateSObject
in interface RestClient
sObjectName
- specified object nameid
- object idsObject
- request entitycallback
- RestClient.ResponseCallback
to handle response or exceptionpublic void deleteSObject(String sObjectName, String id, RestClient.ResponseCallback callback)
RestClient
deleteSObject
in interface RestClient
sObjectName
- specified object nameid
- object idcallback
- RestClient.ResponseCallback
to handle response or exceptionpublic void getSObjectWithId(String sObjectName, String fieldName, String fieldValue, RestClient.ResponseCallback callback)
RestClient
getSObjectWithId
in interface RestClient
sObjectName
- specified object namefieldName
- external field namefieldValue
- external field valuecallback
- RestClient.ResponseCallback
to handle response or exceptionpublic void upsertSObject(String sObjectName, String fieldName, String fieldValue, InputStream sObject, RestClient.ResponseCallback callback)
RestClient
upsertSObject
in interface RestClient
sObjectName
- specified object namefieldName
- external field namefieldValue
- external field valuesObject
- input object to insert or updatecallback
- RestClient.ResponseCallback
to handle response or exceptionpublic void deleteSObjectWithId(String sObjectName, String fieldName, String fieldValue, RestClient.ResponseCallback callback)
RestClient
deleteSObjectWithId
in interface RestClient
sObjectName
- specified object namefieldName
- external field namefieldValue
- external field valuecallback
- RestClient.ResponseCallback
to handle response or exceptionpublic void getBlobField(String sObjectName, String id, String blobFieldName, RestClient.ResponseCallback callback)
RestClient
getBlobField
in interface RestClient
public void query(String soqlQuery, RestClient.ResponseCallback callback)
RestClient
query
in interface RestClient
soqlQuery
- SOQL querycallback
- RestClient.ResponseCallback
to handle response or exceptionpublic void queryMore(String nextRecordsUrl, RestClient.ResponseCallback callback)
RestClient
queryMore
in interface RestClient
nextRecordsUrl
- URL for next records to fetch, returned by query()callback
- RestClient.ResponseCallback
to handle response or exceptionpublic void queryAll(String soqlQuery, RestClient.ResponseCallback callback)
RestClient
queryAll
in interface RestClient
soqlQuery
- SOQL querycallback
- RestClient.ResponseCallback
to handle response or exceptionpublic void search(String soslQuery, RestClient.ResponseCallback callback)
RestClient
search
in interface RestClient
soslQuery
- SOSL querycallback
- RestClient.ResponseCallback
to handle response or exceptionpublic void apexCall(String httpMethod, String apexUrl, Map<String,Object> queryParams, InputStream requestDto, RestClient.ResponseCallback callback)
RestClient
apexCall
in interface RestClient
httpMethod
- HTTP method to execute.apexUrl
- APEX api url.queryParams
- optional query parameters for GET methods, may be empty.requestDto
- optional input DTO for POST, etc. may be null.callback
- RestClient.ResponseCallback
to handle response or exceptionprotected void setAccessToken(org.eclipse.jetty.client.api.Request request)
setAccessToken
in class AbstractClientBase
Apache Camel