data() {
- invokeSafely(ModelCopierSpecWithoutAutoConstructContainersTest::setUp);
- return new ServiceModelCopiers(intermediateModel).copierSpecs().stream()
- .map(spec -> new Object[] { spec, spec.className().simpleName().toLowerCase(Locale.ENGLISH) })
- .collect(toList());
- }
-
- public ModelCopierSpecWithoutAutoConstructContainersTest(ClassSpec spec, String specName) {
- this.spec = spec;
- this.specName = specName;
- }
-
- @Test
- public void basicGeneration() {
- assertThat(spec, generatesTo(expectedFile()));
- }
-
- private String expectedFile() {
- String name = specName + ".java";
- String autoConstructVariant = "./nonautoconstructcontainers/" + name;
- if (getClass().getResource(autoConstructVariant) != null) {
- return autoConstructVariant;
- }
- return name;
- }
-}
diff --git a/codegen/src/test/resources/software/amazon/awssdk/codegen/emitters/customizations/processors/uselegacyeventgenerationscheme/happy-case-customization.config b/codegen/src/test/resources/software/amazon/awssdk/codegen/emitters/customizations/processors/uselegacyeventgenerationscheme/happy-case-customization.config
index 202834524210..8c8a414fcc24 100644
--- a/codegen/src/test/resources/software/amazon/awssdk/codegen/emitters/customizations/processors/uselegacyeventgenerationscheme/happy-case-customization.config
+++ b/codegen/src/test/resources/software/amazon/awssdk/codegen/emitters/customizations/processors/uselegacyeventgenerationscheme/happy-case-customization.config
@@ -1,5 +1,6 @@
{
"useLegacyEventGenerationScheme": {
"EventStream": ["EventOne"]
- }
+ },
+ "underscoresInNameBehavior": "ALLOW"
}
diff --git a/codegen/src/test/resources/software/amazon/awssdk/codegen/emitters/customizations/processors/uselegacyeventgenerationscheme/service-2.json b/codegen/src/test/resources/software/amazon/awssdk/codegen/emitters/customizations/processors/uselegacyeventgenerationscheme/service-2.json
index 4b862fd96839..9d013117fcad 100644
--- a/codegen/src/test/resources/software/amazon/awssdk/codegen/emitters/customizations/processors/uselegacyeventgenerationscheme/service-2.json
+++ b/codegen/src/test/resources/software/amazon/awssdk/codegen/emitters/customizations/processors/uselegacyeventgenerationscheme/service-2.json
@@ -404,16 +404,16 @@
"EventOne": {
"shape": "EventOne"
},
- "event-two": {
+ "event_two": {
"shape": "EventTwo"
},
"secondEventOne": {
"shape": "EventOne"
},
- "second-event-two": {
+ "second_event_two": {
"shape": "EventTwo"
},
- "third-event-two-customizedVisitMethod": {
+ "third_event_two_customizedVisitMethod": {
"shape": "EventTwo"
}
},
diff --git a/codegen/src/test/resources/software/amazon/awssdk/codegen/poet/client/c2j/json/service-2.json b/codegen/src/test/resources/software/amazon/awssdk/codegen/poet/client/c2j/json/service-2.json
index 4670a30fdfa3..d2a5578398b7 100644
--- a/codegen/src/test/resources/software/amazon/awssdk/codegen/poet/client/c2j/json/service-2.json
+++ b/codegen/src/test/resources/software/amazon/awssdk/codegen/poet/client/c2j/json/service-2.json
@@ -13,6 +13,14 @@
"xmlNamespace": "https://json-service.amazonaws.com/doc/2010-05-08/"
},
"operations": {
+ "OperationWithChecksumRequired": {
+ "name": "APostOperation",
+ "http": {
+ "method": "POST",
+ "requestUri": "/"
+ },
+ "httpChecksumRequired": true
+ },
"APostOperation": {
"name": "APostOperation",
"http": {
@@ -404,14 +412,11 @@
"EventOne": {
"shape": "EventOne"
},
- "event-two": {
+ "EventTheSecond": {
"shape": "EventTwo"
},
"secondEventOne": {
"shape": "EventOne"
- },
- "second-event-two": {
- "shape": "EventTwo"
}
},
"eventstream": true
diff --git a/codegen/src/test/resources/software/amazon/awssdk/codegen/poet/client/c2j/query/service-2.json b/codegen/src/test/resources/software/amazon/awssdk/codegen/poet/client/c2j/query/service-2.json
index f1771745a533..2cc6c02c3825 100644
--- a/codegen/src/test/resources/software/amazon/awssdk/codegen/poet/client/c2j/query/service-2.json
+++ b/codegen/src/test/resources/software/amazon/awssdk/codegen/poet/client/c2j/query/service-2.json
@@ -13,6 +13,14 @@
"xmlNamespace": "https://query-service.amazonaws.com/doc/2010-05-08/"
},
"operations": {
+ "OperationWithChecksumRequired": {
+ "name": "APostOperation",
+ "http": {
+ "method": "POST",
+ "requestUri": "/"
+ },
+ "httpChecksumRequired": true
+ },
"APostOperation": {
"name": "APostOperation",
"http": {
diff --git a/codegen/src/test/resources/software/amazon/awssdk/codegen/poet/client/c2j/xml/customization.config b/codegen/src/test/resources/software/amazon/awssdk/codegen/poet/client/c2j/xml/customization.config
new file mode 100644
index 000000000000..dda643384baa
--- /dev/null
+++ b/codegen/src/test/resources/software/amazon/awssdk/codegen/poet/client/c2j/xml/customization.config
@@ -0,0 +1,5 @@
+{
+ "authPolicyActions" : {
+ "skip" : true
+ }
+}
diff --git a/codegen/src/test/resources/software/amazon/awssdk/codegen/poet/client/c2j/xml/service-2.json b/codegen/src/test/resources/software/amazon/awssdk/codegen/poet/client/c2j/xml/service-2.json
new file mode 100644
index 000000000000..bbf395164f8a
--- /dev/null
+++ b/codegen/src/test/resources/software/amazon/awssdk/codegen/poet/client/c2j/xml/service-2.json
@@ -0,0 +1,193 @@
+{
+ "version": "2.0",
+ "metadata": {
+ "apiVersion": "2010-05-08",
+ "endpointPrefix": "xml-service",
+ "globalEndpoint": "xml-service.amazonaws.com",
+ "protocol": "rest-xml",
+ "serviceAbbreviation": "xml Service",
+ "serviceFullName": "Some Service That Uses xml Protocol",
+ "serviceId":"Xml Service",
+ "signatureVersion": "v4",
+ "uid": "xml-service-2010-05-08",
+ "xmlNamespace": "https://xml-service.amazonaws.com/doc/2010-05-08/"
+ },
+ "operations": {
+ "OperationWithChecksumRequired": {
+ "name": "APostOperation",
+ "http": {
+ "method": "POST",
+ "requestUri": "/"
+ },
+ "httpChecksumRequired": true
+ },
+ "APostOperation": {
+ "name": "APostOperation",
+ "http": {
+ "method": "POST",
+ "requestUri": "/"
+ },
+ "endpoint": {
+ "hostPrefix": "foo-"
+ },
+ "input": {
+ "shape": "APostOperationRequest"
+ },
+ "errors": [
+ {
+ "shape": "InvalidInputException"
+ }
+ ],
+ "documentation": "Performs a post operation to the xml service and has no output
"
+ },
+ "APostOperationWithOutput": {
+ "name": "APostOperation",
+ "http": {
+ "method": "POST",
+ "requestUri": "/"
+ },
+ "input": {
+ "shape": "APostOperationWithOutputRequest"
+ },
+ "output": {
+ "shape": "APostOperationWithOutputResponse",
+ "resultWrapper": "APostOperationWithOutputResult"
+ },
+ "errors": [
+ {
+ "shape": "InvalidInputException"
+ }
+ ],
+ "documentation": "Performs a post operation to the xml service and has modelled output
"
+ },
+ "StreamingInputOperation": {
+ "name": "StreamingInputOperation",
+ "http": {
+ "method": "POST",
+ "requestUri": "/2016-03-11/streamingInputOperation"
+ },
+ "input": {
+ "shape": "StructureWithStreamingMember"
+ },
+ "documentation": "Some operation with a streaming input"
+ },
+ "StreamingOutputOperation": {
+ "name": "StreamingOutputOperation",
+ "http": {
+ "method": "POST",
+ "requestUri": "/2016-03-11/streamingOutputOperation"
+ },
+ "output": {
+ "shape": "StructureWithStreamingMember"
+ },
+ "documentation": "Some operation with a streaming output"
+ }
+ },
+ "shapes": {
+ "APostOperationRequest": {
+ "type": "structure",
+ "required": [
+ "SomeNestedMember"
+ ],
+ "members": {
+ "SomeNestedMember": {
+ "shape": "nestedMember",
+ "documentation": "a member that has nested members
"
+ },
+ "OptionalMember": {
+ "shape": "dateType",
+ "documentation": "An optional member
"
+ }
+ }
+ },
+ "APostOperationWithOutputRequest": {
+ "type": "structure",
+ "required": [
+ "SomeNestedMember"
+ ],
+ "members": {
+ "SomeNestedMember": {
+ "shape": "nestedMember",
+ "documentation": "a member that has nested members
"
+ },
+ "OptionalMember": {
+ "shape": "dateType",
+ "documentation": "An optional member
"
+ }
+ }
+ },
+ "APostOperationWithOutputResponse": {
+ "type": "structure",
+ "required": [
+ "NestedMember"
+ ],
+ "members": {
+ "NestedMember": {
+ "shape": "nestedMember",
+ "documentation": "A structure containing nested members
"
+ }
+ },
+ "documentation": "Contains the response to a successful APostOperationWithOutput request.
"
+ },
+ "InvalidInputException": {
+ "type": "structure",
+ "members": {
+ "message": {
+ "shape": "invalidInputMessage"
+ }
+ },
+ "documentation": "The request was rejected because an invalid or out-of-range value was supplied for an input parameter.
",
+ "error": {
+ "code": "InvalidInput",
+ "httpStatusCode": 400,
+ "senderFault": true
+ },
+ "exception": true
+ },
+ "nestedMember": {
+ "type": "structure",
+ "required": [
+ "SubMember",
+ "CreateDate"
+ ],
+ "members": {
+ "SubMember": {
+ "shape": "subMember",
+ "documentation": "A sub-member
"
+ },
+ "CreateDate": {
+ "shape": "dateType",
+ "documentation": "The date and time, in ISO 8601 date-time format, when the member was created.
"
+ }
+ },
+ "documentation": "A shape with nested sub-members"
+ },
+ "subMember": {
+ "type": "string",
+ "max": 63,
+ "min": 3,
+ "pattern": "^[a-z0-9](([a-z0-9]|-(?!-))*[a-z0-9])?$"
+ },
+ "dateType": {
+ "type": "timestamp"
+ },
+ "invalidInputMessage": {
+ "type": "string"
+ },
+ "StreamType": {
+ "type": "blob",
+ "streaming": true
+ },
+ "StructureWithStreamingMember": {
+ "type": "structure",
+ "members": {
+ "StreamingMember": {
+ "shape": "StreamType",
+ "documentation": "This be a stream"
+ }
+ },
+ "payload": "StreamingMember"
+ }
+ },
+ "documentation": "A service that is implemented using the xml protocol"
+}
diff --git a/codegen/src/test/resources/software/amazon/awssdk/codegen/poet/client/test-async-client-class.java b/codegen/src/test/resources/software/amazon/awssdk/codegen/poet/client/test-async-client-class.java
index f8b0a8eac9c0..721b3fa897e4 100644
--- a/codegen/src/test/resources/software/amazon/awssdk/codegen/poet/client/test-async-client-class.java
+++ b/codegen/src/test/resources/software/amazon/awssdk/codegen/poet/client/test-async-client-class.java
@@ -38,6 +38,8 @@
import software.amazon.awssdk.core.client.handler.AttachHttpMetadataResponseHandler;
import software.amazon.awssdk.core.client.handler.ClientExecutionParams;
import software.amazon.awssdk.core.http.HttpResponseHandler;
+import software.amazon.awssdk.core.interceptor.SdkInternalExecutionAttribute;
+import software.amazon.awssdk.core.interceptor.trait.HttpChecksumRequired;
import software.amazon.awssdk.core.metrics.CoreMetric;
import software.amazon.awssdk.core.protocol.VoidSdkResponse;
import software.amazon.awssdk.core.runtime.transform.AsyncStreamingRequestMarshaller;
@@ -75,6 +77,8 @@
import software.amazon.awssdk.services.json.model.InvalidInputException;
import software.amazon.awssdk.services.json.model.JsonException;
import software.amazon.awssdk.services.json.model.JsonRequest;
+import software.amazon.awssdk.services.json.model.OperationWithChecksumRequiredRequest;
+import software.amazon.awssdk.services.json.model.OperationWithChecksumRequiredResponse;
import software.amazon.awssdk.services.json.model.PaginatedOperationWithResultKeyRequest;
import software.amazon.awssdk.services.json.model.PaginatedOperationWithResultKeyResponse;
import software.amazon.awssdk.services.json.model.PaginatedOperationWithoutResultKeyRequest;
@@ -95,6 +99,7 @@
import software.amazon.awssdk.services.json.transform.GetWithoutRequiredMembersRequestMarshaller;
import software.amazon.awssdk.services.json.transform.InputEventMarshaller;
import software.amazon.awssdk.services.json.transform.InputEventTwoMarshaller;
+import software.amazon.awssdk.services.json.transform.OperationWithChecksumRequiredRequestMarshaller;
import software.amazon.awssdk.services.json.transform.PaginatedOperationWithResultKeyRequestMarshaller;
import software.amazon.awssdk.services.json.transform.PaginatedOperationWithoutResultKeyRequestMarshaller;
import software.amazon.awssdk.services.json.transform.StreamingInputOperationRequestMarshaller;
@@ -300,9 +305,8 @@ public CompletableFuture eventStreamOperation(EventStreamOperationRequest
HttpResponseHandler eventResponseHandler = protocolFactory.createResponseHandler(
JsonOperationMetadata.builder().isPayloadJson(true).hasStreamingSuccessResponse(false).build(),
EventStreamTaggedUnionPojoSupplier.builder().putSdkPojoSupplier("EventOne", EventOne::builder)
- .putSdkPojoSupplier("event-two", EventTwo::builder)
+ .putSdkPojoSupplier("EventTheSecond", EventTwo::builder)
.putSdkPojoSupplier("secondEventOne", EventOne::builder)
- .putSdkPojoSupplier("second-event-two", EventTwo::builder)
.defaultSdkPojoSupplier(() -> new SdkPojoBuilder(EventStream.UNKNOWN)).build());
HttpResponseHandler errorResponseHandler = createErrorResponseHandler(protocolFactory,
@@ -327,10 +331,10 @@ public CompletableFuture eventStreamOperation(EventStreamOperationRequest
new ClientExecutionParams()
.withOperationName("EventStreamOperation")
.withMarshaller(new EventStreamOperationRequestMarshaller(protocolFactory))
- .withAsyncRequestBody(software.amazon.awssdk.core.async.AsyncRequestBody.fromPublisher(adapted))
- .withFullDuplex(true).withResponseHandler(responseHandler)
- .withErrorResponseHandler(errorResponseHandler).withMetricCollector(apiCallMetricCollector)
- .withInput(eventStreamOperationRequest), restAsyncResponseTransformer);
+ .withAsyncRequestBody(AsyncRequestBody.fromPublisher(adapted)).withFullDuplex(true)
+ .withResponseHandler(responseHandler).withErrorResponseHandler(errorResponseHandler)
+ .withMetricCollector(apiCallMetricCollector).withInput(eventStreamOperationRequest),
+ restAsyncResponseTransformer);
AwsRequestOverrideConfiguration requestOverrideConfig = eventStreamOperationRequest.overrideConfiguration().orElse(
null);
CompletableFuture whenCompleted = executeFuture.whenComplete((r, e) -> {
@@ -405,9 +409,9 @@ public CompletableFuture eventStreamO
.execute(new ClientExecutionParams()
.withOperationName("EventStreamOperationWithOnlyInput")
.withMarshaller(new EventStreamOperationWithOnlyInputRequestMarshaller(protocolFactory))
- .withAsyncRequestBody(software.amazon.awssdk.core.async.AsyncRequestBody.fromPublisher(adapted))
- .withResponseHandler(responseHandler).withErrorResponseHandler(errorResponseHandler)
- .withMetricCollector(apiCallMetricCollector).withInput(eventStreamOperationWithOnlyInputRequest));
+ .withAsyncRequestBody(AsyncRequestBody.fromPublisher(adapted)).withResponseHandler(responseHandler)
+ .withErrorResponseHandler(errorResponseHandler).withMetricCollector(apiCallMetricCollector)
+ .withInput(eventStreamOperationWithOnlyInputRequest));
AwsRequestOverrideConfiguration requestOverrideConfig = eventStreamOperationWithOnlyInputRequest
.overrideConfiguration().orElse(null);
CompletableFuture whenCompleted = executeFuture.whenComplete((r, e) -> {
@@ -464,9 +468,8 @@ public CompletableFuture eventStreamOperationWithOnlyOutput(
HttpResponseHandler eventResponseHandler = protocolFactory.createResponseHandler(
JsonOperationMetadata.builder().isPayloadJson(true).hasStreamingSuccessResponse(false).build(),
EventStreamTaggedUnionPojoSupplier.builder().putSdkPojoSupplier("EventOne", EventOne::builder)
- .putSdkPojoSupplier("event-two", EventTwo::builder)
+ .putSdkPojoSupplier("EventTheSecond", EventTwo::builder)
.putSdkPojoSupplier("secondEventOne", EventOne::builder)
- .putSdkPojoSupplier("second-event-two", EventTwo::builder)
.defaultSdkPojoSupplier(() -> new SdkPojoBuilder(EventStream.UNKNOWN)).build());
HttpResponseHandler errorResponseHandler = createErrorResponseHandler(protocolFactory,
@@ -573,6 +576,67 @@ public CompletableFuture getWithoutRequiredMe
}
}
+ /**
+ * Invokes the OperationWithChecksumRequired operation asynchronously.
+ *
+ * @param operationWithChecksumRequiredRequest
+ * @return A Java Future containing the result of the OperationWithChecksumRequired operation returned by the
+ * service.
+ * The CompletableFuture returned by this method can be completed exceptionally with the following
+ * exceptions.
+ *
+ * - SdkException Base class for all exceptions that can be thrown by the SDK (both service and client).
+ * Can be used for catch all scenarios.
+ * - SdkClientException If any client side error occurs such as an IO related failure, failure to get
+ * credentials, etc.
+ * - JsonException Base class for all service exceptions. Unknown exceptions will be thrown as an instance
+ * of this type.
+ *
+ * @sample JsonAsyncClient.OperationWithChecksumRequired
+ * @see AWS API Documentation
+ */
+ @Override
+ public CompletableFuture operationWithChecksumRequired(
+ OperationWithChecksumRequiredRequest operationWithChecksumRequiredRequest) {
+ List metricPublishers = resolveMetricPublishers(clientConfiguration,
+ operationWithChecksumRequiredRequest.overrideConfiguration().orElse(null));
+ MetricCollector apiCallMetricCollector = metricPublishers.isEmpty() ? NoOpMetricCollector.create() : MetricCollector
+ .create("ApiCall");
+ try {
+ apiCallMetricCollector.reportMetric(CoreMetric.SERVICE_ID, "Json Service");
+ apiCallMetricCollector.reportMetric(CoreMetric.OPERATION_NAME, "OperationWithChecksumRequired");
+ JsonOperationMetadata operationMetadata = JsonOperationMetadata.builder().hasStreamingSuccessResponse(false)
+ .isPayloadJson(true).build();
+
+ HttpResponseHandler responseHandler = protocolFactory.createResponseHandler(
+ operationMetadata, OperationWithChecksumRequiredResponse::builder);
+
+ HttpResponseHandler errorResponseHandler = createErrorResponseHandler(protocolFactory,
+ operationMetadata);
+
+ CompletableFuture executeFuture = clientHandler
+ .execute(new ClientExecutionParams()
+ .withOperationName("OperationWithChecksumRequired")
+ .withMarshaller(new OperationWithChecksumRequiredRequestMarshaller(protocolFactory))
+ .withResponseHandler(responseHandler)
+ .withErrorResponseHandler(errorResponseHandler)
+ .withMetricCollector(apiCallMetricCollector)
+ .putExecutionAttribute(SdkInternalExecutionAttribute.HTTP_CHECKSUM_REQUIRED,
+ HttpChecksumRequired.create()).withInput(operationWithChecksumRequiredRequest));
+ AwsRequestOverrideConfiguration requestOverrideConfig = operationWithChecksumRequiredRequest.overrideConfiguration()
+ .orElse(null);
+ CompletableFuture whenCompleted = executeFuture.whenComplete((r, e) -> {
+ metricPublishers.forEach(p -> p.publish(apiCallMetricCollector.collect()));
+ });
+ executeFuture = CompletableFutureUtils.forwardExceptionTo(whenCompleted, executeFuture);
+ return executeFuture;
+ } catch (Throwable t) {
+ metricPublishers.forEach(p -> p.publish(apiCallMetricCollector.collect()));
+ return CompletableFutureUtils.failedFuture(t);
+ }
+ }
+
/**
* Some paginated operation with result_key in paginators.json file
*
@@ -653,7 +717,7 @@ public CompletableFuture paginatedOpera
* The following are few ways to use the response class:
*
* 1) Using the subscribe helper method
- *
+ *
*
* {@code
* software.amazon.awssdk.services.json.paginators.PaginatedOperationWithResultKeyPublisher publisher = client.paginatedOperationWithResultKeyPaginator(request);
@@ -663,19 +727,19 @@ public CompletableFuture paginatedOpera
*
*
* 2) Using a custom subscriber
- *
+ *
*
* {@code
* software.amazon.awssdk.services.json.paginators.PaginatedOperationWithResultKeyPublisher publisher = client.paginatedOperationWithResultKeyPaginator(request);
* publisher.subscribe(new Subscriber() {
- *
+ *
* public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
- *
- *
+ *
+ *
* public void onNext(software.amazon.awssdk.services.json.model.PaginatedOperationWithResultKeyResponse response) { //... };
* });}
*
- *
+ *
* As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.
*
* Please notice that the configuration of MaxResults won't limit the number of results you get with the
@@ -788,7 +852,7 @@ public CompletableFuture paginatedOp
* The following are few ways to use the response class:
*
* 1) Using the subscribe helper method
- *
+ *
*
* {@code
* software.amazon.awssdk.services.json.paginators.PaginatedOperationWithoutResultKeyPublisher publisher = client.paginatedOperationWithoutResultKeyPaginator(request);
@@ -798,19 +862,19 @@ public CompletableFuture paginatedOp
*
*
* 2) Using a custom subscriber
- *
+ *
*
* {@code
* software.amazon.awssdk.services.json.paginators.PaginatedOperationWithoutResultKeyPublisher publisher = client.paginatedOperationWithoutResultKeyPaginator(request);
* publisher.subscribe(new Subscriber() {
- *
+ *
* public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
- *
- *
+ *
+ *
* public void onNext(software.amazon.awssdk.services.json.model.PaginatedOperationWithoutResultKeyResponse response) { //... };
* });}
*
- *
+ *
* As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.
*
* Please notice that the configuration of MaxResults won't limit the number of results you get with the
@@ -1129,3 +1193,4 @@ private HttpResponseHandler createErrorResponseHandler(Base
return protocolFactory.createErrorResponseHandler(operationMetadata);
}
}
+
diff --git a/codegen/src/test/resources/software/amazon/awssdk/codegen/poet/client/test-json-async-client-interface.java b/codegen/src/test/resources/software/amazon/awssdk/codegen/poet/client/test-json-async-client-interface.java
index e97f69cd5896..43455c17f37e 100644
--- a/codegen/src/test/resources/software/amazon/awssdk/codegen/poet/client/test-json-async-client-interface.java
+++ b/codegen/src/test/resources/software/amazon/awssdk/codegen/poet/client/test-json-async-client-interface.java
@@ -22,6 +22,8 @@
import software.amazon.awssdk.services.json.model.GetWithoutRequiredMembersResponse;
import software.amazon.awssdk.services.json.model.InputEventStream;
import software.amazon.awssdk.services.json.model.InputEventStreamTwo;
+import software.amazon.awssdk.services.json.model.OperationWithChecksumRequiredRequest;
+import software.amazon.awssdk.services.json.model.OperationWithChecksumRequiredResponse;
import software.amazon.awssdk.services.json.model.PaginatedOperationWithResultKeyRequest;
import software.amazon.awssdk.services.json.model.PaginatedOperationWithResultKeyResponse;
import software.amazon.awssdk.services.json.model.PaginatedOperationWithoutResultKeyRequest;
@@ -145,7 +147,7 @@ default CompletableFuture aPostOperation(ConsumerAWS API Documentation
*/
default CompletableFuture aPostOperationWithOutput(
- APostOperationWithOutputRequest aPostOperationWithOutputRequest) {
+ APostOperationWithOutputRequest aPostOperationWithOutputRequest) {
throw new UnsupportedOperationException();
}
@@ -180,9 +182,9 @@ default CompletableFuture aPostOperationWithOu
* target="_top">AWS API Documentation
*/
default CompletableFuture aPostOperationWithOutput(
- Consumer aPostOperationWithOutputRequest) {
+ Consumer aPostOperationWithOutputRequest) {
return aPostOperationWithOutput(APostOperationWithOutputRequest.builder().applyMutation(aPostOperationWithOutputRequest)
- .build());
+ .build());
}
/**
@@ -205,7 +207,7 @@ default CompletableFuture aPostOperationWithOu
* target="_top">AWS API Documentation
*/
default CompletableFuture eventStreamOperation(EventStreamOperationRequest eventStreamOperationRequest,
- Publisher requestStream, EventStreamOperationResponseHandler asyncResponseHandler) {
+ Publisher requestStream, EventStreamOperationResponseHandler asyncResponseHandler) {
throw new UnsupportedOperationException();
}
@@ -235,10 +237,10 @@ default CompletableFuture eventStreamOperation(EventStreamOperationRequest
* target="_top">AWS API Documentation
*/
default CompletableFuture eventStreamOperation(
- Consumer eventStreamOperationRequest, Publisher requestStream,
- EventStreamOperationResponseHandler asyncResponseHandler) {
+ Consumer eventStreamOperationRequest, Publisher requestStream,
+ EventStreamOperationResponseHandler asyncResponseHandler) {
return eventStreamOperation(EventStreamOperationRequest.builder().applyMutation(eventStreamOperationRequest).build(),
- requestStream, asyncResponseHandler);
+ requestStream, asyncResponseHandler);
}
/**
@@ -262,8 +264,8 @@ default CompletableFuture eventStreamOperation(
* target="_top">AWS API Documentation
*/
default CompletableFuture eventStreamOperationWithOnlyInput(
- EventStreamOperationWithOnlyInputRequest eventStreamOperationWithOnlyInputRequest,
- Publisher requestStream) {
+ EventStreamOperationWithOnlyInputRequest eventStreamOperationWithOnlyInputRequest,
+ Publisher requestStream) {
throw new UnsupportedOperationException();
}
@@ -294,11 +296,11 @@ default CompletableFuture eventStream
* target="_top">AWS API Documentation
*/
default CompletableFuture eventStreamOperationWithOnlyInput(
- Consumer eventStreamOperationWithOnlyInputRequest,
- Publisher requestStream) {
+ Consumer eventStreamOperationWithOnlyInputRequest,
+ Publisher requestStream) {
return eventStreamOperationWithOnlyInput(
- EventStreamOperationWithOnlyInputRequest.builder().applyMutation(eventStreamOperationWithOnlyInputRequest)
- .build(), requestStream);
+ EventStreamOperationWithOnlyInputRequest.builder().applyMutation(eventStreamOperationWithOnlyInputRequest)
+ .build(), requestStream);
}
/**
@@ -322,8 +324,8 @@ default CompletableFuture eventStream
* target="_top">AWS API Documentation
*/
default CompletableFuture eventStreamOperationWithOnlyOutput(
- EventStreamOperationWithOnlyOutputRequest eventStreamOperationWithOnlyOutputRequest,
- EventStreamOperationWithOnlyOutputResponseHandler asyncResponseHandler) {
+ EventStreamOperationWithOnlyOutputRequest eventStreamOperationWithOnlyOutputRequest,
+ EventStreamOperationWithOnlyOutputResponseHandler asyncResponseHandler) {
throw new UnsupportedOperationException();
}
@@ -354,11 +356,11 @@ default CompletableFuture eventStreamOperationWithOnlyOutput(
* target="_top">AWS API Documentation
*/
default CompletableFuture eventStreamOperationWithOnlyOutput(
- Consumer eventStreamOperationWithOnlyOutputRequest,
- EventStreamOperationWithOnlyOutputResponseHandler asyncResponseHandler) {
+ Consumer eventStreamOperationWithOnlyOutputRequest,
+ EventStreamOperationWithOnlyOutputResponseHandler asyncResponseHandler) {
return eventStreamOperationWithOnlyOutput(
- EventStreamOperationWithOnlyOutputRequest.builder().applyMutation(eventStreamOperationWithOnlyOutputRequest)
- .build(), asyncResponseHandler);
+ EventStreamOperationWithOnlyOutputRequest.builder().applyMutation(eventStreamOperationWithOnlyOutputRequest)
+ .build(), asyncResponseHandler);
}
/**
@@ -385,7 +387,7 @@ default CompletableFuture eventStreamOperationWithOnlyOutput(
* target="_top">AWS API Documentation
*/
default CompletableFuture getWithoutRequiredMembers(
- GetWithoutRequiredMembersRequest getWithoutRequiredMembersRequest) {
+ GetWithoutRequiredMembersRequest getWithoutRequiredMembersRequest) {
throw new UnsupportedOperationException();
}
@@ -420,9 +422,66 @@ default CompletableFuture getWithoutRequiredM
* target="_top">AWS API Documentation
*/
default CompletableFuture getWithoutRequiredMembers(
- Consumer getWithoutRequiredMembersRequest) {
+ Consumer getWithoutRequiredMembersRequest) {
return getWithoutRequiredMembers(GetWithoutRequiredMembersRequest.builder()
- .applyMutation(getWithoutRequiredMembersRequest).build());
+ .applyMutation(getWithoutRequiredMembersRequest).build());
+ }
+
+ /**
+ * Invokes the OperationWithChecksumRequired operation asynchronously.
+ *
+ * @param operationWithChecksumRequiredRequest
+ * @return A Java Future containing the result of the OperationWithChecksumRequired operation returned by the
+ * service.
+ * The CompletableFuture returned by this method can be completed exceptionally with the following
+ * exceptions.
+ *
+ * - SdkException Base class for all exceptions that can be thrown by the SDK (both service and client).
+ * Can be used for catch all scenarios.
+ * - SdkClientException If any client side error occurs such as an IO related failure, failure to get
+ * credentials, etc.
+ * - JsonException Base class for all service exceptions. Unknown exceptions will be thrown as an instance
+ * of this type.
+ *
+ * @sample JsonAsyncClient.OperationWithChecksumRequired
+ * @see AWS API Documentation
+ */
+ default CompletableFuture operationWithChecksumRequired(
+ OperationWithChecksumRequiredRequest operationWithChecksumRequiredRequest) {
+ throw new UnsupportedOperationException();
+ }
+
+ /**
+ * Invokes the OperationWithChecksumRequired operation asynchronously.
+ *
+ * This is a convenience which creates an instance of the {@link OperationWithChecksumRequiredRequest.Builder}
+ * avoiding the need to create one manually via {@link OperationWithChecksumRequiredRequest#builder()}
+ *
+ *
+ * @param operationWithChecksumRequiredRequest
+ * A {@link Consumer} that will call methods on {@link OperationWithChecksumRequiredRequest.Builder} to
+ * create a request.
+ * @return A Java Future containing the result of the OperationWithChecksumRequired operation returned by the
+ * service.
+ * The CompletableFuture returned by this method can be completed exceptionally with the following
+ * exceptions.
+ *
+ * - SdkException Base class for all exceptions that can be thrown by the SDK (both service and client).
+ * Can be used for catch all scenarios.
+ * - SdkClientException If any client side error occurs such as an IO related failure, failure to get
+ * credentials, etc.
+ * - JsonException Base class for all service exceptions. Unknown exceptions will be thrown as an instance
+ * of this type.
+ *
+ * @sample JsonAsyncClient.OperationWithChecksumRequired
+ * @see AWS API Documentation
+ */
+ default CompletableFuture operationWithChecksumRequired(
+ Consumer operationWithChecksumRequiredRequest) {
+ return operationWithChecksumRequired(OperationWithChecksumRequiredRequest.builder()
+ .applyMutation(operationWithChecksumRequiredRequest).build());
}
/**
@@ -446,7 +505,7 @@ default CompletableFuture getWithoutRequiredM
* target="_top">AWS API Documentation
*/
default CompletableFuture paginatedOperationWithResultKey(
- PaginatedOperationWithResultKeyRequest paginatedOperationWithResultKeyRequest) {
+ PaginatedOperationWithResultKeyRequest paginatedOperationWithResultKeyRequest) {
throw new UnsupportedOperationException();
}
@@ -477,9 +536,9 @@ default CompletableFuture paginatedOper
* target="_top">AWS API Documentation
*/
default CompletableFuture paginatedOperationWithResultKey(
- Consumer paginatedOperationWithResultKeyRequest) {
+ Consumer paginatedOperationWithResultKeyRequest) {
return paginatedOperationWithResultKey(PaginatedOperationWithResultKeyRequest.builder()
- .applyMutation(paginatedOperationWithResultKeyRequest).build());
+ .applyMutation(paginatedOperationWithResultKeyRequest).build());
}
/**
@@ -653,7 +712,7 @@ default PaginatedOperationWithResultKeyPublisher paginatedOperationWithResultKey
* target="_top">AWS API Documentation
*/
default PaginatedOperationWithResultKeyPublisher paginatedOperationWithResultKeyPaginator(
- PaginatedOperationWithResultKeyRequest paginatedOperationWithResultKeyRequest) {
+ PaginatedOperationWithResultKeyRequest paginatedOperationWithResultKeyRequest) {
throw new UnsupportedOperationException();
}
@@ -736,9 +795,9 @@ default PaginatedOperationWithResultKeyPublisher paginatedOperationWithResultKey
* target="_top">AWS API Documentation
*/
default PaginatedOperationWithResultKeyPublisher paginatedOperationWithResultKeyPaginator(
- Consumer paginatedOperationWithResultKeyRequest) {
+ Consumer paginatedOperationWithResultKeyRequest) {
return paginatedOperationWithResultKeyPaginator(PaginatedOperationWithResultKeyRequest.builder()
- .applyMutation(paginatedOperationWithResultKeyRequest).build());
+ .applyMutation(paginatedOperationWithResultKeyRequest).build());
}
/**
@@ -762,7 +821,7 @@ default PaginatedOperationWithResultKeyPublisher paginatedOperationWithResultKey
* target="_top">AWS API Documentation
*/
default CompletableFuture paginatedOperationWithoutResultKey(
- PaginatedOperationWithoutResultKeyRequest paginatedOperationWithoutResultKeyRequest) {
+ PaginatedOperationWithoutResultKeyRequest paginatedOperationWithoutResultKeyRequest) {
throw new UnsupportedOperationException();
}
@@ -793,9 +852,9 @@ default CompletableFuture paginatedO
* target="_top">AWS API Documentation
*/
default CompletableFuture paginatedOperationWithoutResultKey(
- Consumer paginatedOperationWithoutResultKeyRequest) {
+ Consumer paginatedOperationWithoutResultKeyRequest) {
return paginatedOperationWithoutResultKey(PaginatedOperationWithoutResultKeyRequest.builder()
- .applyMutation(paginatedOperationWithoutResultKeyRequest).build());
+ .applyMutation(paginatedOperationWithoutResultKeyRequest).build());
}
/**
@@ -871,7 +930,7 @@ default CompletableFuture paginatedO
* target="_top">AWS API Documentation
*/
default PaginatedOperationWithoutResultKeyPublisher paginatedOperationWithoutResultKeyPaginator(
- PaginatedOperationWithoutResultKeyRequest paginatedOperationWithoutResultKeyRequest) {
+ PaginatedOperationWithoutResultKeyRequest paginatedOperationWithoutResultKeyRequest) {
throw new UnsupportedOperationException();
}
@@ -954,9 +1013,9 @@ default PaginatedOperationWithoutResultKeyPublisher paginatedOperationWithoutRes
* target="_top">AWS API Documentation
*/
default PaginatedOperationWithoutResultKeyPublisher paginatedOperationWithoutResultKeyPaginator(
- Consumer paginatedOperationWithoutResultKeyRequest) {
+ Consumer paginatedOperationWithoutResultKeyRequest) {
return paginatedOperationWithoutResultKeyPaginator(PaginatedOperationWithoutResultKeyRequest.builder()
- .applyMutation(paginatedOperationWithoutResultKeyRequest).build());
+ .applyMutation(paginatedOperationWithoutResultKeyRequest).build());
}
/**
@@ -984,7 +1043,7 @@ default PaginatedOperationWithoutResultKeyPublisher paginatedOperationWithoutRes
* target="_top">AWS API Documentation
*/
default CompletableFuture streamingInputOperation(
- StreamingInputOperationRequest streamingInputOperationRequest, AsyncRequestBody requestBody) {
+ StreamingInputOperationRequest streamingInputOperationRequest, AsyncRequestBody requestBody) {
throw new UnsupportedOperationException();
}
@@ -1019,9 +1078,9 @@ default CompletableFuture streamingInputOperati
* target="_top">AWS API Documentation
*/
default CompletableFuture streamingInputOperation(
- Consumer streamingInputOperationRequest, AsyncRequestBody requestBody) {
+ Consumer streamingInputOperationRequest, AsyncRequestBody requestBody) {
return streamingInputOperation(StreamingInputOperationRequest.builder().applyMutation(streamingInputOperationRequest)
- .build(), requestBody);
+ .build(), requestBody);
}
/**
@@ -1049,7 +1108,7 @@ default CompletableFuture streamingInputOperati
* target="_top">AWS API Documentation
*/
default CompletableFuture streamingInputOperation(
- StreamingInputOperationRequest streamingInputOperationRequest, Path sourcePath) {
+ StreamingInputOperationRequest streamingInputOperationRequest, Path sourcePath) {
return streamingInputOperation(streamingInputOperationRequest, AsyncRequestBody.fromFile(sourcePath));
}
@@ -1084,9 +1143,9 @@ default CompletableFuture streamingInputOperati
* target="_top">AWS API Documentation
*/
default CompletableFuture streamingInputOperation(
- Consumer streamingInputOperationRequest, Path sourcePath) {
+ Consumer streamingInputOperationRequest, Path sourcePath) {
return streamingInputOperation(StreamingInputOperationRequest.builder().applyMutation(streamingInputOperationRequest)
- .build(), sourcePath);
+ .build(), sourcePath);
}
/**
@@ -1119,8 +1178,8 @@ default CompletableFuture streamingInputOperati
* target="_top">AWS API Documentation
*/
default CompletableFuture streamingInputOutputOperation(
- StreamingInputOutputOperationRequest streamingInputOutputOperationRequest, AsyncRequestBody requestBody,
- AsyncResponseTransformer asyncResponseTransformer) {
+ StreamingInputOutputOperationRequest streamingInputOutputOperationRequest, AsyncRequestBody requestBody,
+ AsyncResponseTransformer asyncResponseTransformer) {
throw new UnsupportedOperationException();
}
@@ -1160,12 +1219,12 @@ default CompletableFuture streamingInputOutputOperation(
* target="_top">AWS API Documentation
*/
default CompletableFuture streamingInputOutputOperation(
- Consumer streamingInputOutputOperationRequest,
- AsyncRequestBody requestBody,
- AsyncResponseTransformer asyncResponseTransformer) {
+ Consumer streamingInputOutputOperationRequest,
+ AsyncRequestBody requestBody,
+ AsyncResponseTransformer asyncResponseTransformer) {
return streamingInputOutputOperation(
- StreamingInputOutputOperationRequest.builder().applyMutation(streamingInputOutputOperationRequest).build(),
- requestBody, asyncResponseTransformer);
+ StreamingInputOutputOperationRequest.builder().applyMutation(streamingInputOutputOperationRequest).build(),
+ requestBody, asyncResponseTransformer);
}
/**
@@ -1197,9 +1256,9 @@ default CompletableFuture streamingInputOutputOperation(
* target="_top">AWS API Documentation
*/
default CompletableFuture streamingInputOutputOperation(
- StreamingInputOutputOperationRequest streamingInputOutputOperationRequest, Path sourcePath, Path destinationPath) {
+ StreamingInputOutputOperationRequest streamingInputOutputOperationRequest, Path sourcePath, Path destinationPath) {
return streamingInputOutputOperation(streamingInputOutputOperationRequest, AsyncRequestBody.fromFile(sourcePath),
- AsyncResponseTransformer.toFile(destinationPath));
+ AsyncResponseTransformer.toFile(destinationPath));
}
/**
@@ -1237,11 +1296,11 @@ default CompletableFuture streamingInputO
* target="_top">AWS API Documentation
*/
default CompletableFuture streamingInputOutputOperation(
- Consumer streamingInputOutputOperationRequest, Path sourcePath,
- Path destinationPath) {
+ Consumer streamingInputOutputOperationRequest, Path sourcePath,
+ Path destinationPath) {
return streamingInputOutputOperation(
- StreamingInputOutputOperationRequest.builder().applyMutation(streamingInputOutputOperationRequest).build(),
- sourcePath, destinationPath);
+ StreamingInputOutputOperationRequest.builder().applyMutation(streamingInputOutputOperationRequest).build(),
+ sourcePath, destinationPath);
}
/**
@@ -1269,8 +1328,8 @@ default CompletableFuture streamingInputO
* target="_top">AWS API Documentation
*/
default CompletableFuture streamingOutputOperation(
- StreamingOutputOperationRequest streamingOutputOperationRequest,
- AsyncResponseTransformer asyncResponseTransformer) {
+ StreamingOutputOperationRequest streamingOutputOperationRequest,
+ AsyncResponseTransformer asyncResponseTransformer) {
throw new UnsupportedOperationException();
}
@@ -1305,10 +1364,10 @@ default CompletableFuture streamingOutputOperation(
* target="_top">AWS API Documentation
*/
default CompletableFuture streamingOutputOperation(
- Consumer streamingOutputOperationRequest,
- AsyncResponseTransformer asyncResponseTransformer) {
+ Consumer streamingOutputOperationRequest,
+ AsyncResponseTransformer asyncResponseTransformer) {
return streamingOutputOperation(StreamingOutputOperationRequest.builder().applyMutation(streamingOutputOperationRequest)
- .build(), asyncResponseTransformer);
+ .build(), asyncResponseTransformer);
}
/**
@@ -1335,7 +1394,7 @@ default CompletableFuture streamingOutputOperation(
* target="_top">AWS API Documentation
*/
default CompletableFuture streamingOutputOperation(
- StreamingOutputOperationRequest streamingOutputOperationRequest, Path destinationPath) {
+ StreamingOutputOperationRequest streamingOutputOperationRequest, Path destinationPath) {
return streamingOutputOperation(streamingOutputOperationRequest, AsyncResponseTransformer.toFile(destinationPath));
}
@@ -1369,9 +1428,9 @@ default CompletableFuture streamingOutputOpera
* target="_top">AWS API Documentation
*/
default CompletableFuture streamingOutputOperation(
- Consumer streamingOutputOperationRequest, Path destinationPath) {
+ Consumer streamingOutputOperationRequest, Path destinationPath) {
return streamingOutputOperation(StreamingOutputOperationRequest.builder().applyMutation(streamingOutputOperationRequest)
- .build(), destinationPath);
+ .build(), destinationPath);
}
/**
diff --git a/codegen/src/test/resources/software/amazon/awssdk/codegen/poet/client/test-json-client-class.java b/codegen/src/test/resources/software/amazon/awssdk/codegen/poet/client/test-json-client-class.java
index 14c934f5b859..b1c99a29788f 100644
--- a/codegen/src/test/resources/software/amazon/awssdk/codegen/poet/client/test-json-client-class.java
+++ b/codegen/src/test/resources/software/amazon/awssdk/codegen/poet/client/test-json-client-class.java
@@ -17,6 +17,8 @@
import software.amazon.awssdk.core.client.handler.SyncClientHandler;
import software.amazon.awssdk.core.exception.SdkClientException;
import software.amazon.awssdk.core.http.HttpResponseHandler;
+import software.amazon.awssdk.core.interceptor.SdkInternalExecutionAttribute;
+import software.amazon.awssdk.core.interceptor.trait.HttpChecksumRequired;
import software.amazon.awssdk.core.metrics.CoreMetric;
import software.amazon.awssdk.core.runtime.transform.StreamingRequestMarshaller;
import software.amazon.awssdk.core.signer.Signer;
@@ -40,6 +42,8 @@
import software.amazon.awssdk.services.json.model.InvalidInputException;
import software.amazon.awssdk.services.json.model.JsonException;
import software.amazon.awssdk.services.json.model.JsonRequest;
+import software.amazon.awssdk.services.json.model.OperationWithChecksumRequiredRequest;
+import software.amazon.awssdk.services.json.model.OperationWithChecksumRequiredResponse;
import software.amazon.awssdk.services.json.model.PaginatedOperationWithResultKeyRequest;
import software.amazon.awssdk.services.json.model.PaginatedOperationWithResultKeyResponse;
import software.amazon.awssdk.services.json.model.PaginatedOperationWithoutResultKeyRequest;
@@ -55,6 +59,7 @@
import software.amazon.awssdk.services.json.transform.APostOperationRequestMarshaller;
import software.amazon.awssdk.services.json.transform.APostOperationWithOutputRequestMarshaller;
import software.amazon.awssdk.services.json.transform.GetWithoutRequiredMembersRequestMarshaller;
+import software.amazon.awssdk.services.json.transform.OperationWithChecksumRequiredRequestMarshaller;
import software.amazon.awssdk.services.json.transform.PaginatedOperationWithResultKeyRequestMarshaller;
import software.amazon.awssdk.services.json.transform.PaginatedOperationWithoutResultKeyRequestMarshaller;
import software.amazon.awssdk.services.json.transform.StreamingInputOperationRequestMarshaller;
@@ -112,32 +117,32 @@ public final String serviceName() {
*/
@Override
public APostOperationResponse aPostOperation(APostOperationRequest aPostOperationRequest) throws InvalidInputException,
- AwsServiceException, SdkClientException, JsonException {
+ AwsServiceException, SdkClientException, JsonException {
JsonOperationMetadata operationMetadata = JsonOperationMetadata.builder().hasStreamingSuccessResponse(false)
- .isPayloadJson(true).build();
+ .isPayloadJson(true).build();
HttpResponseHandler responseHandler = protocolFactory.createResponseHandler(operationMetadata,
- APostOperationResponse::builder);
+ APostOperationResponse::builder);
HttpResponseHandler errorResponseHandler = createErrorResponseHandler(protocolFactory,
- operationMetadata);
+ operationMetadata);
List metricPublishers = resolveMetricPublishers(clientConfiguration, aPostOperationRequest
- .overrideConfiguration().orElse(null));
+ .overrideConfiguration().orElse(null));
MetricCollector apiCallMetricCollector = metricPublishers.isEmpty() ? NoOpMetricCollector.create() : MetricCollector
- .create("ApiCall");
+ .create("ApiCall");
try {
apiCallMetricCollector.reportMetric(CoreMetric.SERVICE_ID, "Json Service");
apiCallMetricCollector.reportMetric(CoreMetric.OPERATION_NAME, "APostOperation");
String hostPrefix = "{StringMember}-foo.";
HostnameValidator.validateHostnameCompliant(aPostOperationRequest.stringMember(), "StringMember",
- "aPostOperationRequest");
+ "aPostOperationRequest");
String resolvedHostExpression = String.format("%s-foo.", aPostOperationRequest.stringMember());
return clientHandler.execute(new ClientExecutionParams()
- .withOperationName("APostOperation").withResponseHandler(responseHandler)
- .withErrorResponseHandler(errorResponseHandler).hostPrefixExpression(resolvedHostExpression)
- .withInput(aPostOperationRequest).withMetricCollector(apiCallMetricCollector)
- .withMarshaller(new APostOperationRequestMarshaller(protocolFactory)));
+ .withOperationName("APostOperation").withResponseHandler(responseHandler)
+ .withErrorResponseHandler(errorResponseHandler).hostPrefixExpression(resolvedHostExpression)
+ .withInput(aPostOperationRequest).withMetricCollector(apiCallMetricCollector)
+ .withMarshaller(new APostOperationRequestMarshaller(protocolFactory)));
} finally {
metricPublishers.forEach(p -> p.publish(apiCallMetricCollector.collect()));
}
@@ -165,30 +170,30 @@ public APostOperationResponse aPostOperation(APostOperationRequest aPostOperatio
*/
@Override
public APostOperationWithOutputResponse aPostOperationWithOutput(
- APostOperationWithOutputRequest aPostOperationWithOutputRequest) throws InvalidInputException, AwsServiceException,
- SdkClientException, JsonException {
+ APostOperationWithOutputRequest aPostOperationWithOutputRequest) throws InvalidInputException, AwsServiceException,
+ SdkClientException, JsonException {
JsonOperationMetadata operationMetadata = JsonOperationMetadata.builder().hasStreamingSuccessResponse(false)
- .isPayloadJson(true).build();
+ .isPayloadJson(true).build();
HttpResponseHandler responseHandler = protocolFactory.createResponseHandler(
- operationMetadata, APostOperationWithOutputResponse::builder);
+ operationMetadata, APostOperationWithOutputResponse::builder);
HttpResponseHandler errorResponseHandler = createErrorResponseHandler(protocolFactory,
- operationMetadata);
+ operationMetadata);
List metricPublishers = resolveMetricPublishers(clientConfiguration, aPostOperationWithOutputRequest
- .overrideConfiguration().orElse(null));
+ .overrideConfiguration().orElse(null));
MetricCollector apiCallMetricCollector = metricPublishers.isEmpty() ? NoOpMetricCollector.create() : MetricCollector
- .create("ApiCall");
+ .create("ApiCall");
try {
apiCallMetricCollector.reportMetric(CoreMetric.SERVICE_ID, "Json Service");
apiCallMetricCollector.reportMetric(CoreMetric.OPERATION_NAME, "APostOperationWithOutput");
return clientHandler
- .execute(new ClientExecutionParams()
- .withOperationName("APostOperationWithOutput").withResponseHandler(responseHandler)
- .withErrorResponseHandler(errorResponseHandler).withInput(aPostOperationWithOutputRequest)
- .withMetricCollector(apiCallMetricCollector)
- .withMarshaller(new APostOperationWithOutputRequestMarshaller(protocolFactory)));
+ .execute(new ClientExecutionParams()
+ .withOperationName("APostOperationWithOutput").withResponseHandler(responseHandler)
+ .withErrorResponseHandler(errorResponseHandler).withInput(aPostOperationWithOutputRequest)
+ .withMetricCollector(apiCallMetricCollector)
+ .withMarshaller(new APostOperationWithOutputRequestMarshaller(protocolFactory)));
} finally {
metricPublishers.forEach(p -> p.publish(apiCallMetricCollector.collect()));
}
@@ -216,30 +221,81 @@ public APostOperationWithOutputResponse aPostOperationWithOutput(
*/
@Override
public GetWithoutRequiredMembersResponse getWithoutRequiredMembers(
- GetWithoutRequiredMembersRequest getWithoutRequiredMembersRequest) throws InvalidInputException, AwsServiceException,
- SdkClientException, JsonException {
+ GetWithoutRequiredMembersRequest getWithoutRequiredMembersRequest) throws InvalidInputException, AwsServiceException,
+ SdkClientException, JsonException {
JsonOperationMetadata operationMetadata = JsonOperationMetadata.builder().hasStreamingSuccessResponse(false)
- .isPayloadJson(true).build();
+ .isPayloadJson(true).build();
HttpResponseHandler responseHandler = protocolFactory.createResponseHandler(
- operationMetadata, GetWithoutRequiredMembersResponse::builder);
+ operationMetadata, GetWithoutRequiredMembersResponse::builder);
HttpResponseHandler errorResponseHandler = createErrorResponseHandler(protocolFactory,
- operationMetadata);
+ operationMetadata);
List metricPublishers = resolveMetricPublishers(clientConfiguration, getWithoutRequiredMembersRequest
- .overrideConfiguration().orElse(null));
+ .overrideConfiguration().orElse(null));
MetricCollector apiCallMetricCollector = metricPublishers.isEmpty() ? NoOpMetricCollector.create() : MetricCollector
- .create("ApiCall");
+ .create("ApiCall");
try {
apiCallMetricCollector.reportMetric(CoreMetric.SERVICE_ID, "Json Service");
apiCallMetricCollector.reportMetric(CoreMetric.OPERATION_NAME, "GetWithoutRequiredMembers");
return clientHandler
- .execute(new ClientExecutionParams()
- .withOperationName("GetWithoutRequiredMembers").withResponseHandler(responseHandler)
- .withErrorResponseHandler(errorResponseHandler).withInput(getWithoutRequiredMembersRequest)
- .withMetricCollector(apiCallMetricCollector)
- .withMarshaller(new GetWithoutRequiredMembersRequestMarshaller(protocolFactory)));
+ .execute(new ClientExecutionParams()
+ .withOperationName("GetWithoutRequiredMembers").withResponseHandler(responseHandler)
+ .withErrorResponseHandler(errorResponseHandler).withInput(getWithoutRequiredMembersRequest)
+ .withMetricCollector(apiCallMetricCollector)
+ .withMarshaller(new GetWithoutRequiredMembersRequestMarshaller(protocolFactory)));
+ } finally {
+ metricPublishers.forEach(p -> p.publish(apiCallMetricCollector.collect()));
+ }
+ }
+
+ /**
+ * Invokes the OperationWithChecksumRequired operation.
+ *
+ * @param operationWithChecksumRequiredRequest
+ * @return Result of the OperationWithChecksumRequired operation returned by the service.
+ * @throws SdkException
+ * Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
+ * catch all scenarios.
+ * @throws SdkClientException
+ * If any client side error occurs such as an IO related failure, failure to get credentials, etc.
+ * @throws JsonException
+ * Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
+ * @sample JsonClient.OperationWithChecksumRequired
+ * @see AWS API Documentation
+ */
+ @Override
+ public OperationWithChecksumRequiredResponse operationWithChecksumRequired(
+ OperationWithChecksumRequiredRequest operationWithChecksumRequiredRequest) throws AwsServiceException,
+ SdkClientException, JsonException {
+ JsonOperationMetadata operationMetadata = JsonOperationMetadata.builder().hasStreamingSuccessResponse(false)
+ .isPayloadJson(true).build();
+
+ HttpResponseHandler responseHandler = protocolFactory.createResponseHandler(
+ operationMetadata, OperationWithChecksumRequiredResponse::builder);
+
+ HttpResponseHandler errorResponseHandler = createErrorResponseHandler(protocolFactory,
+ operationMetadata);
+ List metricPublishers = resolveMetricPublishers(clientConfiguration,
+ operationWithChecksumRequiredRequest.overrideConfiguration().orElse(null));
+ MetricCollector apiCallMetricCollector = metricPublishers.isEmpty() ? NoOpMetricCollector.create() : MetricCollector
+ .create("ApiCall");
+ try {
+ apiCallMetricCollector.reportMetric(CoreMetric.SERVICE_ID, "Json Service");
+ apiCallMetricCollector.reportMetric(CoreMetric.OPERATION_NAME, "OperationWithChecksumRequired");
+
+ return clientHandler
+ .execute(new ClientExecutionParams()
+ .withOperationName("OperationWithChecksumRequired")
+ .withResponseHandler(responseHandler)
+ .withErrorResponseHandler(errorResponseHandler)
+ .withInput(operationWithChecksumRequiredRequest)
+ .withMetricCollector(apiCallMetricCollector)
+ .putExecutionAttribute(SdkInternalExecutionAttribute.HTTP_CHECKSUM_REQUIRED,
+ HttpChecksumRequired.create())
+ .withMarshaller(new OperationWithChecksumRequiredRequestMarshaller(protocolFactory)));
} finally {
metricPublishers.forEach(p -> p.publish(apiCallMetricCollector.collect()));
}
@@ -263,30 +319,30 @@ public GetWithoutRequiredMembersResponse getWithoutRequiredMembers(
*/
@Override
public PaginatedOperationWithResultKeyResponse paginatedOperationWithResultKey(
- PaginatedOperationWithResultKeyRequest paginatedOperationWithResultKeyRequest) throws AwsServiceException,
- SdkClientException, JsonException {
+ PaginatedOperationWithResultKeyRequest paginatedOperationWithResultKeyRequest) throws AwsServiceException,
+ SdkClientException, JsonException {
JsonOperationMetadata operationMetadata = JsonOperationMetadata.builder().hasStreamingSuccessResponse(false)
- .isPayloadJson(true).build();
+ .isPayloadJson(true).build();
HttpResponseHandler responseHandler = protocolFactory.createResponseHandler(
- operationMetadata, PaginatedOperationWithResultKeyResponse::builder);
+ operationMetadata, PaginatedOperationWithResultKeyResponse::builder);
HttpResponseHandler errorResponseHandler = createErrorResponseHandler(protocolFactory,
- operationMetadata);
+ operationMetadata);
List metricPublishers = resolveMetricPublishers(clientConfiguration,
- paginatedOperationWithResultKeyRequest.overrideConfiguration().orElse(null));
+ paginatedOperationWithResultKeyRequest.overrideConfiguration().orElse(null));
MetricCollector apiCallMetricCollector = metricPublishers.isEmpty() ? NoOpMetricCollector.create() : MetricCollector
- .create("ApiCall");
+ .create("ApiCall");
try {
apiCallMetricCollector.reportMetric(CoreMetric.SERVICE_ID, "Json Service");
apiCallMetricCollector.reportMetric(CoreMetric.OPERATION_NAME, "PaginatedOperationWithResultKey");
return clientHandler
- .execute(new ClientExecutionParams()
- .withOperationName("PaginatedOperationWithResultKey").withResponseHandler(responseHandler)
- .withErrorResponseHandler(errorResponseHandler).withInput(paginatedOperationWithResultKeyRequest)
- .withMetricCollector(apiCallMetricCollector)
- .withMarshaller(new PaginatedOperationWithResultKeyRequestMarshaller(protocolFactory)));
+ .execute(new ClientExecutionParams()
+ .withOperationName("PaginatedOperationWithResultKey").withResponseHandler(responseHandler)
+ .withErrorResponseHandler(errorResponseHandler).withInput(paginatedOperationWithResultKeyRequest)
+ .withMetricCollector(apiCallMetricCollector)
+ .withMarshaller(new PaginatedOperationWithResultKeyRequestMarshaller(protocolFactory)));
} finally {
metricPublishers.forEach(p -> p.publish(apiCallMetricCollector.collect()));
}
@@ -365,8 +421,8 @@ public PaginatedOperationWithResultKeyResponse paginatedOperationWithResultKey(
*/
@Override
public PaginatedOperationWithResultKeyIterable paginatedOperationWithResultKeyPaginator(
- PaginatedOperationWithResultKeyRequest paginatedOperationWithResultKeyRequest) throws AwsServiceException,
- SdkClientException, JsonException {
+ PaginatedOperationWithResultKeyRequest paginatedOperationWithResultKeyRequest) throws AwsServiceException,
+ SdkClientException, JsonException {
return new PaginatedOperationWithResultKeyIterable(this, applyPaginatorUserAgent(paginatedOperationWithResultKeyRequest));
}
@@ -388,30 +444,30 @@ public PaginatedOperationWithResultKeyIterable paginatedOperationWithResultKeyPa
*/
@Override
public PaginatedOperationWithoutResultKeyResponse paginatedOperationWithoutResultKey(
- PaginatedOperationWithoutResultKeyRequest paginatedOperationWithoutResultKeyRequest) throws AwsServiceException,
- SdkClientException, JsonException {
+ PaginatedOperationWithoutResultKeyRequest paginatedOperationWithoutResultKeyRequest) throws AwsServiceException,
+ SdkClientException, JsonException {
JsonOperationMetadata operationMetadata = JsonOperationMetadata.builder().hasStreamingSuccessResponse(false)
- .isPayloadJson(true).build();
+ .isPayloadJson(true).build();
HttpResponseHandler responseHandler = protocolFactory.createResponseHandler(
- operationMetadata, PaginatedOperationWithoutResultKeyResponse::builder);
+ operationMetadata, PaginatedOperationWithoutResultKeyResponse::builder);
HttpResponseHandler errorResponseHandler = createErrorResponseHandler(protocolFactory,
- operationMetadata);
+ operationMetadata);
List metricPublishers = resolveMetricPublishers(clientConfiguration,
- paginatedOperationWithoutResultKeyRequest.overrideConfiguration().orElse(null));
+ paginatedOperationWithoutResultKeyRequest.overrideConfiguration().orElse(null));
MetricCollector apiCallMetricCollector = metricPublishers.isEmpty() ? NoOpMetricCollector.create() : MetricCollector
- .create("ApiCall");
+ .create("ApiCall");
try {
apiCallMetricCollector.reportMetric(CoreMetric.SERVICE_ID, "Json Service");
apiCallMetricCollector.reportMetric(CoreMetric.OPERATION_NAME, "PaginatedOperationWithoutResultKey");
return clientHandler
- .execute(new ClientExecutionParams()
- .withOperationName("PaginatedOperationWithoutResultKey").withResponseHandler(responseHandler)
- .withErrorResponseHandler(errorResponseHandler).withInput(paginatedOperationWithoutResultKeyRequest)
- .withMetricCollector(apiCallMetricCollector)
- .withMarshaller(new PaginatedOperationWithoutResultKeyRequestMarshaller(protocolFactory)));
+ .execute(new ClientExecutionParams()
+ .withOperationName("PaginatedOperationWithoutResultKey").withResponseHandler(responseHandler)
+ .withErrorResponseHandler(errorResponseHandler).withInput(paginatedOperationWithoutResultKeyRequest)
+ .withMetricCollector(apiCallMetricCollector)
+ .withMarshaller(new PaginatedOperationWithoutResultKeyRequestMarshaller(protocolFactory)));
} finally {
metricPublishers.forEach(p -> p.publish(apiCallMetricCollector.collect()));
}
@@ -490,10 +546,10 @@ public PaginatedOperationWithoutResultKeyResponse paginatedOperationWithoutResul
*/
@Override
public PaginatedOperationWithoutResultKeyIterable paginatedOperationWithoutResultKeyPaginator(
- PaginatedOperationWithoutResultKeyRequest paginatedOperationWithoutResultKeyRequest) throws AwsServiceException,
- SdkClientException, JsonException {
+ PaginatedOperationWithoutResultKeyRequest paginatedOperationWithoutResultKeyRequest) throws AwsServiceException,
+ SdkClientException, JsonException {
return new PaginatedOperationWithoutResultKeyIterable(this,
- applyPaginatorUserAgent(paginatedOperationWithoutResultKeyRequest));
+ applyPaginatorUserAgent(paginatedOperationWithoutResultKeyRequest));
}
/**
@@ -525,35 +581,35 @@ public PaginatedOperationWithoutResultKeyIterable paginatedOperationWithoutResul
*/
@Override
public StreamingInputOperationResponse streamingInputOperation(StreamingInputOperationRequest streamingInputOperationRequest,
- RequestBody requestBody) throws AwsServiceException, SdkClientException, JsonException {
+ RequestBody requestBody) throws AwsServiceException, SdkClientException, JsonException {
JsonOperationMetadata operationMetadata = JsonOperationMetadata.builder().hasStreamingSuccessResponse(false)
- .isPayloadJson(true).build();
+ .isPayloadJson(true).build();
HttpResponseHandler responseHandler = protocolFactory.createResponseHandler(
- operationMetadata, StreamingInputOperationResponse::builder);
+ operationMetadata, StreamingInputOperationResponse::builder);
HttpResponseHandler errorResponseHandler = createErrorResponseHandler(protocolFactory,
- operationMetadata);
+ operationMetadata);
List metricPublishers = resolveMetricPublishers(clientConfiguration, streamingInputOperationRequest
- .overrideConfiguration().orElse(null));
+ .overrideConfiguration().orElse(null));
MetricCollector apiCallMetricCollector = metricPublishers.isEmpty() ? NoOpMetricCollector.create() : MetricCollector
- .create("ApiCall");
+ .create("ApiCall");
try {
apiCallMetricCollector.reportMetric(CoreMetric.SERVICE_ID, "Json Service");
apiCallMetricCollector.reportMetric(CoreMetric.OPERATION_NAME, "StreamingInputOperation");
return clientHandler
- .execute(new ClientExecutionParams()
- .withOperationName("StreamingInputOperation")
- .withResponseHandler(responseHandler)
- .withErrorResponseHandler(errorResponseHandler)
- .withInput(streamingInputOperationRequest)
- .withMetricCollector(apiCallMetricCollector)
- .withRequestBody(requestBody)
- .withMarshaller(
- StreamingRequestMarshaller.builder()
- .delegateMarshaller(new StreamingInputOperationRequestMarshaller(protocolFactory))
- .requestBody(requestBody).build()));
+ .execute(new ClientExecutionParams()
+ .withOperationName("StreamingInputOperation")
+ .withResponseHandler(responseHandler)
+ .withErrorResponseHandler(errorResponseHandler)
+ .withInput(streamingInputOperationRequest)
+ .withMetricCollector(apiCallMetricCollector)
+ .withRequestBody(requestBody)
+ .withMarshaller(
+ StreamingRequestMarshaller.builder()
+ .delegateMarshaller(new StreamingInputOperationRequestMarshaller(protocolFactory))
+ .requestBody(requestBody).build()));
} finally {
metricPublishers.forEach(p -> p.publish(apiCallMetricCollector.collect()));
}
@@ -595,41 +651,41 @@ public StreamingInputOperationResponse streamingInputOperation(StreamingInputOpe
*/
@Override
public ReturnT streamingInputOutputOperation(
- StreamingInputOutputOperationRequest streamingInputOutputOperationRequest, RequestBody requestBody,
- ResponseTransformer responseTransformer) throws AwsServiceException,
- SdkClientException, JsonException {
+ StreamingInputOutputOperationRequest streamingInputOutputOperationRequest, RequestBody requestBody,
+ ResponseTransformer responseTransformer) throws AwsServiceException,
+ SdkClientException, JsonException {
streamingInputOutputOperationRequest = applySignerOverride(streamingInputOutputOperationRequest,
- Aws4UnsignedPayloadSigner.create());
+ Aws4UnsignedPayloadSigner.create());
JsonOperationMetadata operationMetadata = JsonOperationMetadata.builder().hasStreamingSuccessResponse(true)
- .isPayloadJson(false).build();
+ .isPayloadJson(false).build();
HttpResponseHandler responseHandler = protocolFactory.createResponseHandler(
- operationMetadata, StreamingInputOutputOperationResponse::builder);
+ operationMetadata, StreamingInputOutputOperationResponse::builder);
HttpResponseHandler errorResponseHandler = createErrorResponseHandler(protocolFactory,
- operationMetadata);
+ operationMetadata);
List metricPublishers = resolveMetricPublishers(clientConfiguration,
- streamingInputOutputOperationRequest.overrideConfiguration().orElse(null));
+ streamingInputOutputOperationRequest.overrideConfiguration().orElse(null));
MetricCollector apiCallMetricCollector = metricPublishers.isEmpty() ? NoOpMetricCollector.create() : MetricCollector
- .create("ApiCall");
+ .create("ApiCall");
try {
apiCallMetricCollector.reportMetric(CoreMetric.SERVICE_ID, "Json Service");
apiCallMetricCollector.reportMetric(CoreMetric.OPERATION_NAME, "StreamingInputOutputOperation");
return clientHandler.execute(
- new ClientExecutionParams()
- .withOperationName("StreamingInputOutputOperation")
- .withResponseHandler(responseHandler)
- .withErrorResponseHandler(errorResponseHandler)
- .withInput(streamingInputOutputOperationRequest)
- .withMetricCollector(apiCallMetricCollector)
- .withRequestBody(requestBody)
- .withMarshaller(
- StreamingRequestMarshaller
- .builder()
- .delegateMarshaller(
- new StreamingInputOutputOperationRequestMarshaller(protocolFactory))
- .requestBody(requestBody).transferEncoding(true).build()), responseTransformer);
+ new ClientExecutionParams()
+ .withOperationName("StreamingInputOutputOperation")
+ .withResponseHandler(responseHandler)
+ .withErrorResponseHandler(errorResponseHandler)
+ .withInput(streamingInputOutputOperationRequest)
+ .withMetricCollector(apiCallMetricCollector)
+ .withRequestBody(requestBody)
+ .withMarshaller(
+ StreamingRequestMarshaller
+ .builder()
+ .delegateMarshaller(
+ new StreamingInputOutputOperationRequestMarshaller(protocolFactory))
+ .requestBody(requestBody).transferEncoding(true).build()), responseTransformer);
} finally {
metricPublishers.forEach(p -> p.publish(apiCallMetricCollector.collect()));
}
@@ -660,37 +716,37 @@ public ReturnT streamingInputOutputOperation(
*/
@Override
public ReturnT streamingOutputOperation(StreamingOutputOperationRequest streamingOutputOperationRequest,
- ResponseTransformer responseTransformer) throws AwsServiceException,
- SdkClientException, JsonException {
+ ResponseTransformer responseTransformer) throws AwsServiceException,
+ SdkClientException, JsonException {
JsonOperationMetadata operationMetadata = JsonOperationMetadata.builder().hasStreamingSuccessResponse(true)
- .isPayloadJson(false).build();
+ .isPayloadJson(false).build();
HttpResponseHandler responseHandler = protocolFactory.createResponseHandler(
- operationMetadata, StreamingOutputOperationResponse::builder);
+ operationMetadata, StreamingOutputOperationResponse::builder);
HttpResponseHandler errorResponseHandler = createErrorResponseHandler(protocolFactory,
- operationMetadata);
+ operationMetadata);
List metricPublishers = resolveMetricPublishers(clientConfiguration, streamingOutputOperationRequest
- .overrideConfiguration().orElse(null));
+ .overrideConfiguration().orElse(null));
MetricCollector apiCallMetricCollector = metricPublishers.isEmpty() ? NoOpMetricCollector.create() : MetricCollector
- .create("ApiCall");
+ .create("ApiCall");
try {
apiCallMetricCollector.reportMetric(CoreMetric.SERVICE_ID, "Json Service");
apiCallMetricCollector.reportMetric(CoreMetric.OPERATION_NAME, "StreamingOutputOperation");
return clientHandler.execute(
- new ClientExecutionParams()
- .withOperationName("StreamingOutputOperation").withResponseHandler(responseHandler)
- .withErrorResponseHandler(errorResponseHandler).withInput(streamingOutputOperationRequest)
- .withMetricCollector(apiCallMetricCollector)
- .withMarshaller(new StreamingOutputOperationRequestMarshaller(protocolFactory)), responseTransformer);
+ new ClientExecutionParams()
+ .withOperationName("StreamingOutputOperation").withResponseHandler(responseHandler)
+ .withErrorResponseHandler(errorResponseHandler).withInput(streamingOutputOperationRequest)
+ .withMetricCollector(apiCallMetricCollector)
+ .withMarshaller(new StreamingOutputOperationRequestMarshaller(protocolFactory)), responseTransformer);
} finally {
metricPublishers.forEach(p -> p.publish(apiCallMetricCollector.collect()));
}
}
private static List resolveMetricPublishers(SdkClientConfiguration clientConfiguration,
- RequestOverrideConfiguration requestOverrideConfiguration) {
+ RequestOverrideConfiguration requestOverrideConfiguration) {
List publishers = null;
if (requestOverrideConfiguration != null) {
publishers = requestOverrideConfiguration.metricPublishers();
@@ -705,19 +761,19 @@ private static List resolveMetricPublishers(SdkClientConfigurat
}
private HttpResponseHandler createErrorResponseHandler(BaseAwsJsonProtocolFactory protocolFactory,
- JsonOperationMetadata operationMetadata) {
+ JsonOperationMetadata operationMetadata) {
return protocolFactory.createErrorResponseHandler(operationMetadata);
}
private > T init(T builder) {
return builder
- .clientConfiguration(clientConfiguration)
- .defaultServiceExceptionSupplier(JsonException::builder)
- .protocol(AwsJsonProtocol.REST_JSON)
- .protocolVersion("1.1")
- .registerModeledException(
- ExceptionMetadata.builder().errorCode("InvalidInput")
- .exceptionBuilderSupplier(InvalidInputException::builder).httpStatusCode(400).build());
+ .clientConfiguration(clientConfiguration)
+ .defaultServiceExceptionSupplier(JsonException::builder)
+ .protocol(AwsJsonProtocol.REST_JSON)
+ .protocolVersion("1.1")
+ .registerModeledException(
+ ExceptionMetadata.builder().errorCode("InvalidInput")
+ .exceptionBuilderSupplier(InvalidInputException::builder).httpStatusCode(400).build());
}
@Override
@@ -727,10 +783,10 @@ public void close() {
private T applyPaginatorUserAgent(T request) {
Consumer userAgentApplier = b -> b.addApiName(ApiName.builder()
- .version(VersionInfo.SDK_VERSION).name("PAGINATED").build());
+ .version(VersionInfo.SDK_VERSION).name("PAGINATED").build());
AwsRequestOverrideConfiguration overrideConfiguration = request.overrideConfiguration()
- .map(c -> c.toBuilder().applyMutation(userAgentApplier).build())
- .orElse((AwsRequestOverrideConfiguration.builder().applyMutation(userAgentApplier).build()));
+ .map(c -> c.toBuilder().applyMutation(userAgentApplier).build())
+ .orElse((AwsRequestOverrideConfiguration.builder().applyMutation(userAgentApplier).build()));
return (T) request.toBuilder().overrideConfiguration(overrideConfiguration).build();
}
@@ -740,8 +796,8 @@ private T applySignerOverride(T request, Signer signer)
}
Consumer signerOverride = b -> b.signer(signer).build();
AwsRequestOverrideConfiguration overrideConfiguration = request.overrideConfiguration()
- .map(c -> c.toBuilder().applyMutation(signerOverride).build())
- .orElse((AwsRequestOverrideConfiguration.builder().applyMutation(signerOverride).build()));
+ .map(c -> c.toBuilder().applyMutation(signerOverride).build())
+ .orElse((AwsRequestOverrideConfiguration.builder().applyMutation(signerOverride).build()));
return (T) request.toBuilder().overrideConfiguration(overrideConfiguration).build();
}
diff --git a/codegen/src/test/resources/software/amazon/awssdk/codegen/poet/client/test-json-client-interface.java b/codegen/src/test/resources/software/amazon/awssdk/codegen/poet/client/test-json-client-interface.java
index 2685e7061b1f..77c4aa00dc3d 100644
--- a/codegen/src/test/resources/software/amazon/awssdk/codegen/poet/client/test-json-client-interface.java
+++ b/codegen/src/test/resources/software/amazon/awssdk/codegen/poet/client/test-json-client-interface.java
@@ -19,6 +19,8 @@
import software.amazon.awssdk.services.json.model.GetWithoutRequiredMembersResponse;
import software.amazon.awssdk.services.json.model.InvalidInputException;
import software.amazon.awssdk.services.json.model.JsonException;
+import software.amazon.awssdk.services.json.model.OperationWithChecksumRequiredRequest;
+import software.amazon.awssdk.services.json.model.OperationWithChecksumRequiredResponse;
import software.amazon.awssdk.services.json.model.PaginatedOperationWithResultKeyRequest;
import software.amazon.awssdk.services.json.model.PaginatedOperationWithResultKeyResponse;
import software.amazon.awssdk.services.json.model.PaginatedOperationWithoutResultKeyRequest;
@@ -109,7 +111,7 @@ default APostOperationResponse aPostOperation(APostOperationRequest aPostOperati
* API Documentation
*/
default APostOperationResponse aPostOperation(Consumer aPostOperationRequest)
- throws InvalidInputException, AwsServiceException, SdkClientException, JsonException {
+ throws InvalidInputException, AwsServiceException, SdkClientException, JsonException {
return aPostOperation(APostOperationRequest.builder().applyMutation(aPostOperationRequest).build());
}
@@ -134,8 +136,8 @@ default APostOperationResponse aPostOperation(ConsumerAWS API Documentation
*/
default APostOperationWithOutputResponse aPostOperationWithOutput(
- APostOperationWithOutputRequest aPostOperationWithOutputRequest) throws InvalidInputException, AwsServiceException,
- SdkClientException, JsonException {
+ APostOperationWithOutputRequest aPostOperationWithOutputRequest) throws InvalidInputException, AwsServiceException,
+ SdkClientException, JsonException {
throw new UnsupportedOperationException();
}
@@ -167,8 +169,8 @@ default APostOperationWithOutputResponse aPostOperationWithOutput(
* target="_top">AWS API Documentation
*/
default APostOperationWithOutputResponse aPostOperationWithOutput(
- Consumer aPostOperationWithOutputRequest) throws InvalidInputException,
- AwsServiceException, SdkClientException, JsonException {
+ Consumer aPostOperationWithOutputRequest) throws InvalidInputException,
+ AwsServiceException, SdkClientException, JsonException {
return aPostOperationWithOutput(APostOperationWithOutputRequest.builder().applyMutation(aPostOperationWithOutputRequest)
.build());
}
@@ -194,8 +196,8 @@ default APostOperationWithOutputResponse aPostOperationWithOutput(
* target="_top">AWS API Documentation
*/
default GetWithoutRequiredMembersResponse getWithoutRequiredMembers(
- GetWithoutRequiredMembersRequest getWithoutRequiredMembersRequest) throws InvalidInputException, AwsServiceException,
- SdkClientException, JsonException {
+ GetWithoutRequiredMembersRequest getWithoutRequiredMembersRequest) throws InvalidInputException, AwsServiceException,
+ SdkClientException, JsonException {
throw new UnsupportedOperationException();
}
@@ -227,12 +229,63 @@ default GetWithoutRequiredMembersResponse getWithoutRequiredMembers(
* target="_top">AWS API Documentation
*/
default GetWithoutRequiredMembersResponse getWithoutRequiredMembers(
- Consumer getWithoutRequiredMembersRequest) throws InvalidInputException,
- AwsServiceException, SdkClientException, JsonException {
+ Consumer getWithoutRequiredMembersRequest) throws InvalidInputException,
+ AwsServiceException, SdkClientException, JsonException {
return getWithoutRequiredMembers(GetWithoutRequiredMembersRequest.builder()
.applyMutation(getWithoutRequiredMembersRequest).build());
}
+ /**
+ * Invokes the OperationWithChecksumRequired operation.
+ *
+ * @param operationWithChecksumRequiredRequest
+ * @return Result of the OperationWithChecksumRequired operation returned by the service.
+ * @throws SdkException
+ * Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
+ * catch all scenarios.
+ * @throws SdkClientException
+ * If any client side error occurs such as an IO related failure, failure to get credentials, etc.
+ * @throws JsonException
+ * Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
+ * @sample JsonClient.OperationWithChecksumRequired
+ * @see AWS API Documentation
+ */
+ default OperationWithChecksumRequiredResponse operationWithChecksumRequired(
+ OperationWithChecksumRequiredRequest operationWithChecksumRequiredRequest) throws AwsServiceException,
+ SdkClientException, JsonException {
+ throw new UnsupportedOperationException();
+ }
+
+ /**
+ * Invokes the OperationWithChecksumRequired operation.
+ *
+ * This is a convenience which creates an instance of the {@link OperationWithChecksumRequiredRequest.Builder}
+ * avoiding the need to create one manually via {@link OperationWithChecksumRequiredRequest#builder()}
+ *
+ *
+ * @param operationWithChecksumRequiredRequest
+ * A {@link Consumer} that will call methods on {@link OperationWithChecksumRequiredRequest.Builder} to
+ * create a request.
+ * @return Result of the OperationWithChecksumRequired operation returned by the service.
+ * @throws SdkException
+ * Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
+ * catch all scenarios.
+ * @throws SdkClientException
+ * If any client side error occurs such as an IO related failure, failure to get credentials, etc.
+ * @throws JsonException
+ * Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
+ * @sample JsonClient.OperationWithChecksumRequired
+ * @see AWS API Documentation
+ */
+ default OperationWithChecksumRequiredResponse operationWithChecksumRequired(
+ Consumer operationWithChecksumRequiredRequest)
+ throws AwsServiceException, SdkClientException, JsonException {
+ return operationWithChecksumRequired(OperationWithChecksumRequiredRequest.builder()
+ .applyMutation(operationWithChecksumRequiredRequest).build());
+ }
+
/**
* Some paginated operation with result_key in paginators.json file
*
@@ -271,8 +324,8 @@ default PaginatedOperationWithResultKeyResponse paginatedOperationWithResultKey(
* target="_top">AWS API Documentation
*/
default PaginatedOperationWithResultKeyResponse paginatedOperationWithResultKey(
- PaginatedOperationWithResultKeyRequest paginatedOperationWithResultKeyRequest) throws AwsServiceException,
- SdkClientException, JsonException {
+ PaginatedOperationWithResultKeyRequest paginatedOperationWithResultKeyRequest) throws AwsServiceException,
+ SdkClientException, JsonException {
throw new UnsupportedOperationException();
}
@@ -299,8 +352,8 @@ default PaginatedOperationWithResultKeyResponse paginatedOperationWithResultKey(
* target="_top">AWS API Documentation
*/
default PaginatedOperationWithResultKeyResponse paginatedOperationWithResultKey(
- Consumer paginatedOperationWithResultKeyRequest)
- throws AwsServiceException, SdkClientException, JsonException {
+ Consumer paginatedOperationWithResultKeyRequest)
+ throws AwsServiceException, SdkClientException, JsonException {
return paginatedOperationWithResultKey(PaginatedOperationWithResultKeyRequest.builder()
.applyMutation(paginatedOperationWithResultKeyRequest).build());
}
@@ -453,8 +506,8 @@ default PaginatedOperationWithResultKeyIterable paginatedOperationWithResultKeyP
* target="_top">AWS API Documentation
*/
default PaginatedOperationWithResultKeyIterable paginatedOperationWithResultKeyPaginator(
- PaginatedOperationWithResultKeyRequest paginatedOperationWithResultKeyRequest) throws AwsServiceException,
- SdkClientException, JsonException {
+ PaginatedOperationWithResultKeyRequest paginatedOperationWithResultKeyRequest) throws AwsServiceException,
+ SdkClientException, JsonException {
throw new UnsupportedOperationException();
}
@@ -536,8 +589,8 @@ default PaginatedOperationWithResultKeyIterable paginatedOperationWithResultKeyP
* target="_top">AWS API Documentation
*/
default PaginatedOperationWithResultKeyIterable paginatedOperationWithResultKeyPaginator(
- Consumer paginatedOperationWithResultKeyRequest)
- throws AwsServiceException, SdkClientException, JsonException {
+ Consumer paginatedOperationWithResultKeyRequest)
+ throws AwsServiceException, SdkClientException, JsonException {
return paginatedOperationWithResultKeyPaginator(PaginatedOperationWithResultKeyRequest.builder()
.applyMutation(paginatedOperationWithResultKeyRequest).build());
}
@@ -559,8 +612,8 @@ default PaginatedOperationWithResultKeyIterable paginatedOperationWithResultKeyP
* target="_top">AWS API Documentation
*/
default PaginatedOperationWithoutResultKeyResponse paginatedOperationWithoutResultKey(
- PaginatedOperationWithoutResultKeyRequest paginatedOperationWithoutResultKeyRequest) throws AwsServiceException,
- SdkClientException, JsonException {
+ PaginatedOperationWithoutResultKeyRequest paginatedOperationWithoutResultKeyRequest) throws AwsServiceException,
+ SdkClientException, JsonException {
throw new UnsupportedOperationException();
}
@@ -587,8 +640,8 @@ default PaginatedOperationWithoutResultKeyResponse paginatedOperationWithoutResu
* target="_top">AWS API Documentation
*/
default PaginatedOperationWithoutResultKeyResponse paginatedOperationWithoutResultKey(
- Consumer paginatedOperationWithoutResultKeyRequest)
- throws AwsServiceException, SdkClientException, JsonException {
+ Consumer paginatedOperationWithoutResultKeyRequest)
+ throws AwsServiceException, SdkClientException, JsonException {
return paginatedOperationWithoutResultKey(PaginatedOperationWithoutResultKeyRequest.builder()
.applyMutation(paginatedOperationWithoutResultKeyRequest).build());
}
@@ -665,8 +718,8 @@ default PaginatedOperationWithoutResultKeyResponse paginatedOperationWithoutResu
* target="_top">AWS API Documentation
*/
default PaginatedOperationWithoutResultKeyIterable paginatedOperationWithoutResultKeyPaginator(
- PaginatedOperationWithoutResultKeyRequest paginatedOperationWithoutResultKeyRequest) throws AwsServiceException,
- SdkClientException, JsonException {
+ PaginatedOperationWithoutResultKeyRequest paginatedOperationWithoutResultKeyRequest) throws AwsServiceException,
+ SdkClientException, JsonException {
throw new UnsupportedOperationException();
}
@@ -748,8 +801,8 @@ default PaginatedOperationWithoutResultKeyIterable paginatedOperationWithoutResu
* target="_top">AWS API Documentation
*/
default PaginatedOperationWithoutResultKeyIterable paginatedOperationWithoutResultKeyPaginator(
- Consumer paginatedOperationWithoutResultKeyRequest)
- throws AwsServiceException, SdkClientException, JsonException {
+ Consumer paginatedOperationWithoutResultKeyRequest)
+ throws AwsServiceException, SdkClientException, JsonException {
return paginatedOperationWithoutResultKeyPaginator(PaginatedOperationWithoutResultKeyRequest.builder()
.applyMutation(paginatedOperationWithoutResultKeyRequest).build());
}
@@ -782,8 +835,8 @@ default PaginatedOperationWithoutResultKeyIterable paginatedOperationWithoutResu
* target="_top">AWS API Documentation
*/
default StreamingInputOperationResponse streamingInputOperation(
- StreamingInputOperationRequest streamingInputOperationRequest, RequestBody requestBody) throws AwsServiceException,
- SdkClientException, JsonException {
+ StreamingInputOperationRequest streamingInputOperationRequest, RequestBody requestBody) throws AwsServiceException,
+ SdkClientException, JsonException {
throw new UnsupportedOperationException();
}
@@ -821,8 +874,8 @@ default StreamingInputOperationResponse streamingInputOperation(
* target="_top">AWS API Documentation
*/
default StreamingInputOperationResponse streamingInputOperation(
- Consumer streamingInputOperationRequest, RequestBody requestBody)
- throws AwsServiceException, SdkClientException, JsonException {
+ Consumer streamingInputOperationRequest, RequestBody requestBody)
+ throws AwsServiceException, SdkClientException, JsonException {
return streamingInputOperation(StreamingInputOperationRequest.builder().applyMutation(streamingInputOperationRequest)
.build(), requestBody);
}
@@ -850,8 +903,8 @@ default StreamingInputOperationResponse streamingInputOperation(
* target="_top">AWS API Documentation
*/
default StreamingInputOperationResponse streamingInputOperation(
- StreamingInputOperationRequest streamingInputOperationRequest, Path sourcePath) throws AwsServiceException,
- SdkClientException, JsonException {
+ StreamingInputOperationRequest streamingInputOperationRequest, Path sourcePath) throws AwsServiceException,
+ SdkClientException, JsonException {
return streamingInputOperation(streamingInputOperationRequest, RequestBody.fromFile(sourcePath));
}
@@ -884,8 +937,8 @@ default StreamingInputOperationResponse streamingInputOperation(
* target="_top">AWS API Documentation
*/
default StreamingInputOperationResponse streamingInputOperation(
- Consumer streamingInputOperationRequest, Path sourcePath)
- throws AwsServiceException, SdkClientException, JsonException {
+ Consumer streamingInputOperationRequest, Path sourcePath)
+ throws AwsServiceException, SdkClientException, JsonException {
return streamingInputOperation(StreamingInputOperationRequest.builder().applyMutation(streamingInputOperationRequest)
.build(), sourcePath);
}
@@ -907,11 +960,11 @@ default StreamingInputOperationResponse streamingInputOperation(
* The service documentation for the request content is as follows 'This be a stream'
* @param responseTransformer
* Functional interface for processing the streamed response content. The unmarshalled
- * StreamingInputOutputOperationResponse and an InputStream to the response content are provided as parameters
- * to the callback. The callback may return a transformed type which will be the return value of this method.
- * See {@link software.amazon.awssdk.core.sync.ResponseTransformer} for details on implementing this
- * interface and for links to pre-canned implementations for common scenarios like downloading to a file. The
- * service documentation for the response content is as follows 'This be a stream'.
+ * StreamingInputOutputOperationResponse and an InputStream to the response content are provided as
+ * parameters to the callback. The callback may return a transformed type which will be the return value of
+ * this method. See {@link software.amazon.awssdk.core.sync.ResponseTransformer} for details on implementing
+ * this interface and for links to pre-canned implementations for common scenarios like downloading to a
+ * file. The service documentation for the response content is as follows 'This be a stream'.
* @return The transformed result of the ResponseTransformer.
* @throws SdkException
* Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
@@ -925,9 +978,9 @@ default StreamingInputOperationResponse streamingInputOperation(
* target="_top">AWS API Documentation
*/
default ReturnT streamingInputOutputOperation(
- StreamingInputOutputOperationRequest streamingInputOutputOperationRequest, RequestBody requestBody,
- ResponseTransformer responseTransformer) throws AwsServiceException,
- SdkClientException, JsonException {
+ StreamingInputOutputOperationRequest streamingInputOutputOperationRequest, RequestBody requestBody,
+ ResponseTransformer responseTransformer) throws AwsServiceException,
+ SdkClientException, JsonException {
throw new UnsupportedOperationException();
}
@@ -954,11 +1007,11 @@ default ReturnT streamingInputOutputOperation(
* The service documentation for the request content is as follows 'This be a stream'
* @param responseTransformer
* Functional interface for processing the streamed response content. The unmarshalled
- * StreamingInputOutputOperationResponse and an InputStream to the response content are provided as parameters
- * to the callback. The callback may return a transformed type which will be the return value of this method.
- * See {@link software.amazon.awssdk.core.sync.ResponseTransformer} for details on implementing this
- * interface and for links to pre-canned implementations for common scenarios like downloading to a file. The
- * service documentation for the response content is as follows 'This be a stream'.
+ * StreamingInputOutputOperationResponse and an InputStream to the response content are provided as
+ * parameters to the callback. The callback may return a transformed type which will be the return value of
+ * this method. See {@link software.amazon.awssdk.core.sync.ResponseTransformer} for details on implementing
+ * this interface and for links to pre-canned implementations for common scenarios like downloading to a
+ * file. The service documentation for the response content is as follows 'This be a stream'.
* @return The transformed result of the ResponseTransformer.
* @throws SdkException
* Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for
@@ -972,12 +1025,12 @@ default ReturnT streamingInputOutputOperation(
* target="_top">AWS API Documentation
*/
default ReturnT streamingInputOutputOperation(
- Consumer streamingInputOutputOperationRequest, RequestBody requestBody,
- ResponseTransformer responseTransformer) throws AwsServiceException,
- SdkClientException, JsonException {
+ Consumer streamingInputOutputOperationRequest, RequestBody requestBody,
+ ResponseTransformer responseTransformer) throws AwsServiceException,
+ SdkClientException, JsonException {
return streamingInputOutputOperation(
- StreamingInputOutputOperationRequest.builder().applyMutation(streamingInputOutputOperationRequest).build(),
- requestBody, responseTransformer);
+ StreamingInputOutputOperationRequest.builder().applyMutation(streamingInputOutputOperationRequest).build(),
+ requestBody, responseTransformer);
}
/**
@@ -1008,8 +1061,8 @@ default ReturnT streamingInputOutputOperation(
* target="_top">AWS API Documentation
*/
default StreamingInputOutputOperationResponse streamingInputOutputOperation(
- StreamingInputOutputOperationRequest streamingInputOutputOperationRequest, Path sourcePath, Path destinationPath)
- throws AwsServiceException, SdkClientException, JsonException {
+ StreamingInputOutputOperationRequest streamingInputOutputOperationRequest, Path sourcePath, Path destinationPath)
+ throws AwsServiceException, SdkClientException, JsonException {
return streamingInputOutputOperation(streamingInputOutputOperationRequest, RequestBody.fromFile(sourcePath),
ResponseTransformer.toFile(destinationPath));
}
@@ -1048,11 +1101,11 @@ default StreamingInputOutputOperationResponse streamingInputOutputOperation(
* target="_top">AWS API Documentation
*/
default StreamingInputOutputOperationResponse streamingInputOutputOperation(
- Consumer streamingInputOutputOperationRequest, Path sourcePath,
- Path destinationPath) throws AwsServiceException, SdkClientException, JsonException {
+ Consumer streamingInputOutputOperationRequest, Path sourcePath,
+ Path destinationPath) throws AwsServiceException, SdkClientException, JsonException {
return streamingInputOutputOperation(
- StreamingInputOutputOperationRequest.builder().applyMutation(streamingInputOutputOperationRequest).build(),
- sourcePath, destinationPath);
+ StreamingInputOutputOperationRequest.builder().applyMutation(streamingInputOutputOperationRequest).build(),
+ sourcePath, destinationPath);
}
/**
@@ -1061,8 +1114,8 @@ default StreamingInputOutputOperationResponse streamingInputOutputOperation(
* @param streamingOutputOperationRequest
* @param responseTransformer
* Functional interface for processing the streamed response content. The unmarshalled
- * StreamingOutputOperationResponse and an InputStream to the response content are provided as parameters
- * to the callback. The callback may return a transformed type which will be the return value of this method.
+ * StreamingOutputOperationResponse and an InputStream to the response content are provided as parameters to
+ * the callback. The callback may return a transformed type which will be the return value of this method.
* See {@link software.amazon.awssdk.core.sync.ResponseTransformer} for details on implementing this
* interface and for links to pre-canned implementations for common scenarios like downloading to a file. The
* service documentation for the response content is as follows 'This be a stream'.
@@ -1096,8 +1149,8 @@ default ReturnT streamingOutputOperation(StreamingOutputOperationReque
* request.
* @param responseTransformer
* Functional interface for processing the streamed response content. The unmarshalled
- * StreamingOutputOperationResponse and an InputStream to the response content are provided as parameters
- * to the callback. The callback may return a transformed type which will be the return value of this method.
+ * StreamingOutputOperationResponse and an InputStream to the response content are provided as parameters to
+ * the callback. The callback may return a transformed type which will be the return value of this method.
* See {@link software.amazon.awssdk.core.sync.ResponseTransformer} for details on implementing this
* interface and for links to pre-canned implementations for common scenarios like downloading to a file. The
* service documentation for the response content is as follows 'This be a stream'.
@@ -1114,9 +1167,9 @@ default ReturnT streamingOutputOperation(StreamingOutputOperationReque
* target="_top">AWS API Documentation
*/
default ReturnT streamingOutputOperation(
- Consumer streamingOutputOperationRequest,
- ResponseTransformer responseTransformer) throws AwsServiceException,
- SdkClientException, JsonException {
+ Consumer streamingOutputOperationRequest,
+ ResponseTransformer responseTransformer) throws AwsServiceException,
+ SdkClientException, JsonException {
return streamingOutputOperation(StreamingOutputOperationRequest.builder().applyMutation(streamingOutputOperationRequest)
.build(), responseTransformer);
}
@@ -1143,8 +1196,8 @@ default ReturnT streamingOutputOperation(
* target="_top">AWS API Documentation
*/
default StreamingOutputOperationResponse streamingOutputOperation(
- StreamingOutputOperationRequest streamingOutputOperationRequest, Path destinationPath) throws AwsServiceException,
- SdkClientException, JsonException {
+ StreamingOutputOperationRequest streamingOutputOperationRequest, Path destinationPath) throws AwsServiceException,
+ SdkClientException, JsonException {
return streamingOutputOperation(streamingOutputOperationRequest, ResponseTransformer.toFile(destinationPath));
}
@@ -1176,8 +1229,8 @@ default StreamingOutputOperationResponse streamingOutputOperation(
* target="_top">AWS API Documentation
*/
default StreamingOutputOperationResponse streamingOutputOperation(
- Consumer streamingOutputOperationRequest, Path destinationPath)
- throws AwsServiceException, SdkClientException, JsonException {
+ Consumer streamingOutputOperationRequest, Path destinationPath)
+ throws AwsServiceException, SdkClientException, JsonException {
return streamingOutputOperation(StreamingOutputOperationRequest.builder().applyMutation(streamingOutputOperationRequest)
.build(), destinationPath);
}
@@ -1205,8 +1258,8 @@ default StreamingOutputOperationResponse streamingOutputOperation(
* target="_top">AWS API Documentation
*/
default ResponseInputStream streamingOutputOperation(
- StreamingOutputOperationRequest streamingOutputOperationRequest) throws AwsServiceException, SdkClientException,
- JsonException {
+ StreamingOutputOperationRequest streamingOutputOperationRequest) throws AwsServiceException, SdkClientException,
+ JsonException {
return streamingOutputOperation(streamingOutputOperationRequest, ResponseTransformer.toInputStream());
}
@@ -1239,8 +1292,8 @@ default ResponseInputStream