public void handleRequest()

in TerraformCustomResourceHandler/src/main/java/com/amazon/servicecatalog/terraform/customresource/TerraformLaunchRequestHandler.java [50:68]


    public void handleRequest(InputStream inputStream, OutputStream outputStream, Context context) {
        MessageAttributeValue accountIdValue = new MessageAttributeValue()
                .withDataType("String")
                .withStringValue(getAccountId(context));
        Map<String, MessageAttributeValue> messageAttributes =
                ImmutableMap.of(ACCOUNT_ID_ATTRIBUTE_KEY, accountIdValue);

        String hubSnsTopicArn = EnvConfig.getRequiredEnv(HUB_SNS_ARN_ENV_VAR);
        String cfnRequest = toRequestString(inputStream);

        try {
            publishNotification(hubSnsTopicArn, cfnRequest, messageAttributes);
        } catch (RuntimeException e) {
            CustomResourceRequest request = CustomResourceMarshaller.readCustomResourceRequest(cfnRequest, true);
            String message = String.format("Unable to publish SNS notification to hub account SNS topic. %s",
                                            e.getMessage());
            ResponsePoster.postFailure(request, message);
        }
    }