implement client authorization when performing bulk request to a secure
ES
update content type support by ES
Issue-ID: AAI-1883
Change-Id: I72bd3af0af4680b55fd74c6e7fbd77990fa0ee5b
Signed-off-by: renealr <reneal.rogers@amdocs.com>
import java.util.Properties;
import java.util.concurrent.atomic.AtomicBoolean;
import javax.ws.rs.HttpMethod;
import java.util.Properties;
import java.util.concurrent.atomic.AtomicBoolean;
import javax.ws.rs.HttpMethod;
+import javax.ws.rs.core.MediaType;
import javax.ws.rs.core.Response.Status;
import javax.ws.rs.core.UriBuilder;
import org.eclipse.jetty.http.HttpStatus;
import javax.ws.rs.core.Response.Status;
import javax.ws.rs.core.UriBuilder;
import org.eclipse.jetty.http.HttpStatus;
"{\"index\":{\"_index\":\"%s\",\"_type\":\"%s\",\"_id\":\"%s\", \"_version\":\"%s\"}}\n";
private static final String BULK_DELETE_TEMPLATE =
"{ \"delete\": { \"_index\": \"%s\", \"_type\": \"%s\", \"_id\": \"%s\", \"_version\":\"%s\"}}\n";
"{\"index\":{\"_index\":\"%s\",\"_type\":\"%s\",\"_id\":\"%s\", \"_version\":\"%s\"}}\n";
private static final String BULK_DELETE_TEMPLATE =
"{ \"delete\": { \"_index\": \"%s\", \"_type\": \"%s\", \"_id\": \"%s\", \"_version\":\"%s\"}}\n";
+ public final static String APPLICATION_XND_JSON_TYPE = new MediaType("application", "x-ndjson").toString();
private final ElasticSearchConfig config;
private final ElasticSearchConfig config;
conn = (HttpURLConnection) buildUrl(createUriBuilder("_bulk")).openConnection();
conn.setRequestMethod(HttpMethod.PUT);
conn.setDoOutput(true);
conn = (HttpURLConnection) buildUrl(createUriBuilder("_bulk")).openConnection();
conn.setRequestMethod(HttpMethod.PUT);
conn.setDoOutput(true);
- conn.setRequestProperty(CONTENT_TYPE, APPLICATION_FORM_URLENCODED);
+ conn.setRequestProperty(CONTENT_TYPE, APPLICATION_XND_JSON_TYPE);
+ if(config.useAuth()){
+ conn.setRequestProperty("Authorization", config.getAuthValue());
+ }
conn.setRequestProperty("Connection", "Close");
} catch (IOException e) {
conn.setRequestProperty("Connection", "Close");
} catch (IOException e) {