import java.util.concurrent.atomic.AtomicBoolean;
import javax.ws.rs.HttpMethod;
import javax.ws.rs.core.Response.Status;
-import javax.ws.rs.core.Response.Status.Family;
import javax.ws.rs.core.UriBuilder;
import org.eclipse.jetty.http.HttpStatus;
import org.json.simple.JSONArray;
MdcOverride override = getStartTime(new MdcOverride());
HttpURLConnection conn = createConnection(url, HttpMethod.PUT);
-
-
attachDocument(conn, document);
-
opResult = getOperationResult(conn);
buildDocumentResult(opResult, indexName);
InputStream inputStream = null;
- if (!isSuccessCode(resultCode)) {
+ if (!ApiUtils.isSuccessStatusCode(resultCode)) {
inputStream = conn.getErrorStream();
} else {
try {
}
private boolean isSuccess(OperationResult result) {
- return isSuccessCode(result.getResultCode());
- }
-
- private boolean isSuccessCode(int statusCode) {
- return Family.familyOf(statusCode).equals(Family.SUCCESSFUL);
+ return ApiUtils.isSuccessStatusCode(result.getResultCode());
}
private UriBuilder createUriBuilder(String path, String... paths) {
// Increment the operation counts.
totalOps++;
- if (isSuccessCode(item.operationStatus().getStatus())) {
+ if (ApiUtils.isSuccessStatusCode(item.operationStatus().getStatus())) {
totalSuccess++;
} else {
totalFails++;