File tree Expand file tree Collapse file tree 2 files changed +5
-4
lines changed
main/java/org/opensearch/sdk/sample/helloworld/rest
test/java/org/opensearch/sdk/rest Expand file tree Collapse file tree 2 files changed +5
-4
lines changed Original file line number Diff line number Diff line change 1111
1212import org .opensearch .OpenSearchParseException ;
1313import org .opensearch .core .common .bytes .BytesReference ;
14+ import org .opensearch .core .xcontent .MediaType ;
1415import org .opensearch .core .xcontent .XContentBuilder ;
1516import org .opensearch .common .xcontent .XContentType ;
1617import org .opensearch .common .xcontent .json .JsonXContent ;
@@ -100,11 +101,11 @@ public List<NamedRoute> routes() {
100101 private Function <RestRequest , RestResponse > handlePostRequest = (request ) -> {
101102 if (request .hasContent ()) {
102103 String adjective = "" ;
103- XContentType contentType = request .getXContentType ();
104- if (contentType == null ) {
104+ MediaType mediaType = request .getMediaType ();
105+ if (mediaType == null ) {
105106 // Plain text
106107 adjective = request .content ().utf8ToString ();
107- } else if (contentType .equals (XContentType .JSON )) {
108+ } else if (mediaType .equals (XContentType .JSON )) {
108109 try {
109110 adjective = request .contentParser ().mapStrings ().get ("adjective" );
110111 } catch (IOException | OpenSearchParseException e ) {
Original file line number Diff line number Diff line change @@ -56,7 +56,7 @@ public void testSDKRestRequestMethods() throws IOException {
5656 assertEquals (expectedPath , sdkRestRequest .path ());
5757 assertEquals (expectedParams , sdkRestRequest .params ());
5858 assertEquals (expectedHeaders , sdkRestRequest .getHeaders ());
59- assertEquals (exptectedXContentType , sdkRestRequest .getXContentType ());
59+ assertEquals (exptectedXContentType , sdkRestRequest .getMediaType ());
6060 assertEquals (expectedContent , sdkRestRequest .content ());
6161
6262 Map <String , String > source = sdkRestRequest .contentParser ().mapStrings ();
You can’t perform that action at this time.
0 commit comments