public class HttpJsonRequest extends Object implements CleanCloseable
Modifier and Type | Field and Description |
---|---|
static String |
clientVersion |
static int |
CUSTOM_BUILD_VERSION |
static int |
MINIMUM_SERVER_VERSION |
Constructor and Description |
---|
HttpJsonRequest(CreateHttpJsonRequestParams requestParams,
HttpJsonRequestFactory factory) |
Modifier and Type | Method and Description |
---|---|
HttpJsonRequest |
addOperationHeader(String key,
String value) |
HttpJsonRequest |
addOperationHeaders(Map<String,String> operationsHeaders) |
HttpJsonRequest |
addReplicationStatusHeaders(String thePrimaryUrl,
String currentUrl,
IDocumentStoreReplicationInformer replicationInformer,
FailoverBehaviorSet failoverBehavior,
ServerClient.HandleReplicationStatusChangesCallback handleReplicationStatusChangesCallback) |
double |
calculateDuration() |
void |
close() |
org.apache.http.client.methods.CloseableHttpResponse |
executeRawRequest(RemoteBulkInsertOperation.BulkInsertEntity bulkInsertEntity) |
org.apache.http.client.methods.CloseableHttpResponse |
executeRawResponse() |
org.apache.http.client.methods.CloseableHttpResponse |
executeRawResponse(String data) |
org.apache.http.client.methods.CloseableHttpResponse |
executeRawResponseInternal(org.apache.http.HttpEntity content) |
void |
executeRequest() |
static Map<String,String> |
extractHeaders(org.apache.http.Header[] httpResponseHeaders) |
CachedRequest |
getCachedRequestDetails() |
HttpMethods |
getMethod() |
org.apache.http.client.methods.CloseableHttpResponse |
getResponse() |
Map<String,String> |
getResponseHeaders() |
int |
getResponseStatusCode() |
long |
getSize() |
Long |
getTimeout() |
String |
getUrl() |
protected void |
handleForbiddenResponse(org.apache.http.HttpResponse forbiddenResponse) |
boolean |
isShouldCacheRequest() |
boolean |
isSkipServerCheck() |
byte[] |
readResponseBytes() |
RavenJToken |
readResponseJson() |
void |
removeAuthorizationHeader() |
IObservable<String> |
serverPull() |
void |
setCachedRequestDetails(CachedRequest cachedRequestDetails) |
void |
setResponseHeaders(Map<String,String> responseHeaders) |
void |
setResponseStatusCode(int responseStatusCode) |
void |
setShouldCacheRequest(boolean shouldCacheRequest) |
void |
setSkipServerCheck(boolean skipServerCheck) |
void |
setTimeout(org.apache.http.client.methods.HttpRequestBase requestBase,
long timeoutInMilis) |
void |
write(InputStream streamToWrite) |
void |
write(String data) |
public static final int MINIMUM_SERVER_VERSION
public static final int CUSTOM_BUILD_VERSION
public static final String clientVersion
public HttpJsonRequest(CreateHttpJsonRequestParams requestParams, HttpJsonRequestFactory factory)
public void removeAuthorizationHeader()
public RavenJToken readResponseJson()
public byte[] readResponseBytes() throws IOException
IOException
public void executeRequest()
protected void handleForbiddenResponse(org.apache.http.HttpResponse forbiddenResponse)
public HttpJsonRequest addOperationHeaders(Map<String,String> operationsHeaders)
public HttpJsonRequest addOperationHeader(String key, String value)
public HttpJsonRequest addReplicationStatusHeaders(String thePrimaryUrl, String currentUrl, IDocumentStoreReplicationInformer replicationInformer, FailoverBehaviorSet failoverBehavior, ServerClient.HandleReplicationStatusChangesCallback handleReplicationStatusChangesCallback)
public double calculateDuration()
public IObservable<String> serverPull()
public void write(InputStream streamToWrite)
public void write(String data)
public org.apache.http.client.methods.CloseableHttpResponse executeRawResponse(String data) throws IOException
IOException
public org.apache.http.client.methods.CloseableHttpResponse executeRawResponse()
public org.apache.http.client.methods.CloseableHttpResponse executeRawResponseInternal(org.apache.http.HttpEntity content)
public static Map<String,String> extractHeaders(org.apache.http.Header[] httpResponseHeaders)
public void setTimeout(org.apache.http.client.methods.HttpRequestBase requestBase, long timeoutInMilis)
public void close()
close
in interface Closeable
close
in interface AutoCloseable
close
in interface CleanCloseable
public CachedRequest getCachedRequestDetails()
public String getUrl()
public HttpMethods getMethod()
public long getSize()
public int getResponseStatusCode()
public boolean isShouldCacheRequest()
public boolean isSkipServerCheck()
public void setSkipServerCheck(boolean skipServerCheck)
public void setCachedRequestDetails(CachedRequest cachedRequestDetails)
public Long getTimeout()
public org.apache.http.client.methods.CloseableHttpResponse getResponse()
public void setShouldCacheRequest(boolean shouldCacheRequest)
public void setResponseStatusCode(int responseStatusCode)
public org.apache.http.client.methods.CloseableHttpResponse executeRawRequest(RemoteBulkInsertOperation.BulkInsertEntity bulkInsertEntity)
Copyright © 2016. All Rights Reserved.