public class HttpJsonRequest
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
clientVersion |
Constructor and Description |
---|
HttpJsonRequest(CreateHttpJsonRequestParams requestParams,
HttpJsonRequestFactory factory) |
Modifier and Type | Method and Description |
---|---|
HttpJsonRequest |
addOperationHeader(java.lang.String key,
java.lang.String value) |
HttpJsonRequest |
addOperationHeaders(java.util.Map<java.lang.String,java.lang.String> operationsHeaders) |
HttpJsonRequest |
addReplicationStatusHeaders(java.lang.String thePrimaryUrl,
java.lang.String currentUrl,
IDocumentStoreReplicationInformer replicationInformer,
FailoverBehaviorSet failoverBehavior,
ServerClient.HandleReplicationStatusChangesCallback handleReplicationStatusChangesCallback) |
double |
calculateDuration() |
void |
executeRequest() |
static java.util.Map<java.lang.String,java.lang.String> |
extractHeaders(org.apache.http.Header[] httpResponseHeaders) |
CachedRequest |
getCachedRequestDetails() |
HttpMethods |
getMethod() |
java.util.Map<java.lang.String,java.lang.String> |
getResponseHeaders() |
int |
getResponseStatusCode() |
boolean |
getShouldCacheRequest() |
long |
getSize() |
java.lang.String |
getUrl() |
org.apache.http.client.methods.HttpUriRequest |
getWebRequest() |
protected void |
handleForbiddenResponse(org.apache.http.HttpResponse forbiddenResponse) |
boolean |
isSkipServerCheck() |
org.apache.http.client.methods.CloseableHttpResponse |
rawExecuteRequest()
Remember to release resources in HttpResponse entity!
|
byte[] |
readResponseBytes() |
RavenJToken |
readResponseJson() |
void |
removeAuthorizationHeader() |
IObservable<java.lang.String> |
serverPull() |
void |
setCachedRequestDetails(CachedRequest cachedRequest) |
void |
setResponseHeaders(java.util.Map<java.lang.String,java.lang.String> map) |
void |
setResponseStatusCode(int statusCode) |
void |
setShouldCacheRequest(boolean b) |
void |
setSkipServerCheck(boolean skipServerCheck) |
void |
setTimeout(long timeoutInMilis) |
void |
write(java.io.InputStream is) |
void |
write(java.lang.String data) |
public static final java.lang.String clientVersion
public HttpJsonRequest(CreateHttpJsonRequestParams requestParams, HttpJsonRequestFactory factory)
public long getSize()
public HttpMethods getMethod()
public java.lang.String getUrl()
public boolean isSkipServerCheck()
public void removeAuthorizationHeader()
public CachedRequest getCachedRequestDetails()
public void executeRequest()
public byte[] readResponseBytes() throws java.io.IOException
java.io.IOException
public static java.util.Map<java.lang.String,java.lang.String> extractHeaders(org.apache.http.Header[] httpResponseHeaders)
public int getResponseStatusCode()
public RavenJToken readResponseJson()
public double calculateDuration()
public java.util.Map<java.lang.String,java.lang.String> getResponseHeaders()
protected void handleForbiddenResponse(org.apache.http.HttpResponse forbiddenResponse)
public HttpJsonRequest addOperationHeaders(java.util.Map<java.lang.String,java.lang.String> operationsHeaders)
public HttpJsonRequest addOperationHeader(java.lang.String key, java.lang.String value)
public void write(java.io.InputStream is)
public org.apache.http.client.methods.CloseableHttpResponse rawExecuteRequest()
public void write(java.lang.String data)
public void setShouldCacheRequest(boolean b)
public boolean getShouldCacheRequest()
public void setCachedRequestDetails(CachedRequest cachedRequest)
public void setSkipServerCheck(boolean skipServerCheck)
public org.apache.http.client.methods.HttpUriRequest getWebRequest()
public void setResponseStatusCode(int statusCode)
public void setResponseHeaders(java.util.Map<java.lang.String,java.lang.String> map)
public HttpJsonRequest addReplicationStatusHeaders(java.lang.String thePrimaryUrl, java.lang.String currentUrl, IDocumentStoreReplicationInformer replicationInformer, FailoverBehaviorSet failoverBehavior, ServerClient.HandleReplicationStatusChangesCallback handleReplicationStatusChangesCallback)
public void setTimeout(long timeoutInMilis)
public IObservable<java.lang.String> serverPull()
Copyright © 2014. All Rights Reserved.