com.amazonaws.serverless.proxy.spark

Class SparkLambdaContainerHandler<RequestType,ResponseType>

java.lang.Object

com.amazonaws.serverless.proxy.internal.LambdaContainerHandler<RequestType,ResponseType,AwsProxyHttpServletRequest,AwsHttpServletResponse>

com.amazonaws.serverless.proxy.spark.SparkLambdaContainerHandler<RequestType,ResponseType>

Type Parameters:

RequestType - The request object used by the RequestReader implementation passed to the constructor

ResponseType - The response object produced by the ResponseWriter implementation in the constructor

public class SparkLambdaContainerHandler<RequestType,ResponseType>
extends LambdaContainerHandler<RequestType,ResponseType,AwsProxyHttpServletRequest,AwsHttpServletResponse>

Implementation of the LambdaContainerHandler object that supports the Spark framework: http://sparkjava.com/ Because of the way this container is implemented, using reflection to change accessibility of methods in the Spark framework and inserting itself as the default embedded container, it is important that you initialize the Handler before declaring your spark routes. This implementation uses the default AwsProxyHttpServletRequest and Response implementations.

 
     // always initialize the handler first
     SparkLambdaContainerHandler<AwsProxyRequest, AwsProxyResponse> handler =
             SparkLambdaContainerHandler.getAwsProxyHandler();

     get("/hello", (req, res) -> {
         res.status(200);
         res.body("Hello World");
     });
 
 

Constructor Summary

Constructors

Constructor and Description
SparkLambdaContainerHandler(RequestReader<RequestType,AwsProxyHttpServletRequest> requestReader, ResponseWriter<AwsHttpServletResponse,ResponseType> responseWriter, SecurityContextWriter<RequestType> securityContextWriter, ExceptionHandler<ResponseType> exceptionHandler)

Method Summary

Modifier and Type	Method and Description
static SparkLambdaContainerHandler<AwsProxyRequest,AwsProxyResponse>	getAwsProxyHandler() Returns a new instance of an SparkLambdaContainerHandler initialized to work with AwsProxyRequest and AwsProxyResponse objects.
protected AwsHttpServletResponse	getContainerResponse(java.util.concurrent.CountDownLatch latch)
protected void	handleRequest(AwsProxyHttpServletRequest httpServletRequest, AwsHttpServletResponse httpServletResponse, com.amazonaws.services.lambda.runtime.Context lambdaContext)

Methods inherited from class com.amazonaws.serverless.proxy.internal.LambdaContainerHandler

proxy

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SparkLambdaContainerHandler

public SparkLambdaContainerHandler(RequestReader<RequestType,AwsProxyHttpServletRequest> requestReader,
                                   ResponseWriter<AwsHttpServletResponse,ResponseType> responseWriter,
                                   SecurityContextWriter<RequestType> securityContextWriter,
                                   ExceptionHandler<ResponseType> exceptionHandler)
                            throws ContainerInitializationException

Throws:

ContainerInitializationException

Method Detail

getAwsProxyHandler

public static SparkLambdaContainerHandler<AwsProxyRequest,AwsProxyResponse> getAwsProxyHandler()
                                                                                        throws ContainerInitializationException

Returns a new instance of an SparkLambdaContainerHandler initialized to work with AwsProxyRequest and AwsProxyResponse objects.

Returns:

a new instance of SparkLambdaContainerHandler

Throws:

ContainerInitializationException - Throws this exception if we fail to initialize the Spark container. This could be caused by the introspection used to insert the library as the default embedded container

getContainerResponse

protected AwsHttpServletResponse getContainerResponse(java.util.concurrent.CountDownLatch latch)

Specified by:

getContainerResponse in class LambdaContainerHandler<RequestType,ResponseType,AwsProxyHttpServletRequest,AwsHttpServletResponse>

handleRequest

protected void handleRequest(AwsProxyHttpServletRequest httpServletRequest,
                             AwsHttpServletResponse httpServletResponse,
                             com.amazonaws.services.lambda.runtime.Context lambdaContext)
                      throws java.lang.Exception

Specified by:

handleRequest in class LambdaContainerHandler<RequestType,ResponseType,AwsProxyHttpServletRequest,AwsHttpServletResponse>

Throws:

java.lang.Exception