com.amazonaws.serverless.proxy.spark

Class SparkLambdaContainerHandler<RequestType,ResponseType>

java.lang.Object

com.amazonaws.serverless.proxy.internal.LambdaContainerHandler<RequestType,ResponseType,ContainerRequestType,ContainerResponseType>

com.amazonaws.serverless.proxy.internal.servlet.AwsLambdaServletContainerHandler<RequestType,ResponseType,javax.servlet.http.HttpServletRequest,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 AwsLambdaServletContainerHandler<RequestType,ResponseType,javax.servlet.http.HttpServletRequest,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");
     });
 
 

Nested Class Summary

Nested classes/interfaces inherited from class com.amazonaws.serverless.proxy.internal.servlet.AwsLambdaServletContainerHandler

AwsLambdaServletContainerHandler.StartupHandler

Field Summary

Fields inherited from class com.amazonaws.serverless.proxy.internal.servlet.AwsLambdaServletContainerHandler

servletContext, startupHandler

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

lambdaContext, SERVER_INFO

Constructor Summary

Constructors

Constructor and Description

SparkLambdaContainerHandler(Class<RequestType> requestTypeClass, Class<ResponseType> responseTypeClass, RequestReader<RequestType,javax.servlet.http.HttpServletRequest> requestReader, ResponseWriter<AwsHttpServletResponse,ResponseType> responseWriter, SecurityContextWriter<RequestType> securityContextWriter, ExceptionHandler<ResponseType> exceptionHandler, LambdaEmbeddedServerFactory embeddedServerFactory)

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(javax.servlet.http.HttpServletRequest request, CountDownLatch latch)
static SparkLambdaContainerHandler<HttpApiV2ProxyRequest,AwsProxyResponse>	getHttpApiV2ProxyHandler() Returns a new instance of an SparkLambdaContainerHandler initialized to work with HttpApiV2ProxyRequest and AwsProxyResponse objects.
javax.servlet.Servlet	getServlet()
protected void	handleRequest(javax.servlet.http.HttpServletRequest httpServletRequest, AwsHttpServletResponse httpServletResponse, com.amazonaws.services.lambda.runtime.Context lambdaContext)
void	initialize()

Methods inherited from class com.amazonaws.serverless.proxy.internal.servlet.AwsLambdaServletContainerHandler

doFilter, getFilterChain, getServletContext, onStartup, setServletContext

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

getContainerConfig, getInitializationWrapper, getObjectMapper, proxy, proxyStream, setInitializationWrapper, setLogFormatter, stripBasePath

Methods inherited from class java.lang.Object

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

Constructor Detail

SparkLambdaContainerHandler

public SparkLambdaContainerHandler(Class<RequestType> requestTypeClass,
                                   Class<ResponseType> responseTypeClass,
                                   RequestReader<RequestType,javax.servlet.http.HttpServletRequest> requestReader,
                                   ResponseWriter<AwsHttpServletResponse,ResponseType> responseWriter,
                                   SecurityContextWriter<RequestType> securityContextWriter,
                                   ExceptionHandler<ResponseType> exceptionHandler,
                                   LambdaEmbeddedServerFactory embeddedServerFactory)
                            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

getHttpApiV2ProxyHandler

public static SparkLambdaContainerHandler<HttpApiV2ProxyRequest,AwsProxyResponse> getHttpApiV2ProxyHandler()
                                                                                                    throws ContainerInitializationException

Returns a new instance of an SparkLambdaContainerHandler initialized to work with HttpApiV2ProxyRequest 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(javax.servlet.http.HttpServletRequest request,
                                                      CountDownLatch latch)

Specified by:

getContainerResponse in class LambdaContainerHandler<RequestType,ResponseType,javax.servlet.http.HttpServletRequest,AwsHttpServletResponse>

handleRequest

protected void handleRequest(javax.servlet.http.HttpServletRequest httpServletRequest,
                             AwsHttpServletResponse httpServletResponse,
                             com.amazonaws.services.lambda.runtime.Context lambdaContext)
                      throws Exception

Specified by:

handleRequest in class LambdaContainerHandler<RequestType,ResponseType,javax.servlet.http.HttpServletRequest,AwsHttpServletResponse>

Throws:

Exception

initialize

public void initialize()
                throws ContainerInitializationException

Overrides:

initialize in class AwsLambdaServletContainerHandler<RequestType,ResponseType,javax.servlet.http.HttpServletRequest,AwsHttpServletResponse>

Throws:

ContainerInitializationException

getServlet

public javax.servlet.Servlet getServlet()