io.micronaut.function.aws.proxy

Class MicronautLambdaContainerHandler

java.lang.Object

io.micronaut.function.aws.proxy.AbstractLambdaContainerHandler<com.amazonaws.serverless.proxy.model.AwsProxyRequest,com.amazonaws.serverless.proxy.model.AwsProxyResponse,MicronautAwsProxyRequest<?>,MicronautAwsProxyResponse<?>>

io.micronaut.function.aws.proxy.MicronautLambdaContainerHandler

All Implemented Interfaces:

io.micronaut.context.ApplicationContextProvider, java.io.Closeable, java.lang.AutoCloseable

public final class MicronautLambdaContainerHandler
extends AbstractLambdaContainerHandler<com.amazonaws.serverless.proxy.model.AwsProxyRequest,com.amazonaws.serverless.proxy.model.AwsProxyResponse,MicronautAwsProxyRequest<?>,MicronautAwsProxyResponse<?>>
implements io.micronaut.context.ApplicationContextProvider, java.io.Closeable, java.lang.AutoCloseable

Main entry for AWS API proxy with Micronaut.

Since:

1.1

Author:

graemerocher

Field Summary

Fields inherited from class io.micronaut.function.aws.proxy.AbstractLambdaContainerHandler

lambdaContext, SERVER_INFO

Method Summary

Modifier and Type	Method and Description
void	close()
io.micronaut.context.ApplicationContext	getApplicationContext()
static MicronautLambdaContainerHandler	getAwsProxyHandler() Gets a new MicronautLambdaContainerHandler should be called exactly once.
static MicronautLambdaContainerHandler	getAwsProxyHandler(io.micronaut.context.ApplicationContextBuilder builder) Gets a new MicronautLambdaContainerHandler should be called exactly once.
protected MicronautAwsProxyResponse<?>	getContainerResponse(MicronautAwsProxyRequest<?> request, java.util.concurrent.CountDownLatch latch) Get the container response.
protected void	handleRequest(MicronautAwsProxyRequest<?> containerRequest, MicronautAwsProxyResponse<?> containerResponse, com.amazonaws.services.lambda.runtime.Context lambdaContext) Handle the request.
void	initialize() Initialize the container.
protected com.fasterxml.jackson.databind.ObjectMapper	objectMapper() The object mapper.
protected com.fasterxml.jackson.databind.ObjectReader	readerFor(java.lang.Class<com.amazonaws.serverless.proxy.model.AwsProxyRequest> requestClass) Gets a reader for the given request class.
protected com.fasterxml.jackson.databind.ObjectWriter	writerFor(java.lang.Class<com.amazonaws.serverless.proxy.model.AwsProxyResponse> responseClass) Gets a writer for the given response class.

Methods inherited from class io.micronaut.function.aws.proxy.AbstractLambdaContainerHandler

getContainerConfig, proxy, proxyStream, setLogFormatter, stripBasePath

Methods inherited from class java.lang.Object

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

Method Detail

getAwsProxyHandler

public static MicronautLambdaContainerHandler getAwsProxyHandler()
                                                          throws com.amazonaws.serverless.exceptions.ContainerInitializationException

Gets a new MicronautLambdaContainerHandler should be called exactly once.

Returns:

The MicronautLambdaContainerHandler

Throws:

com.amazonaws.serverless.exceptions.ContainerInitializationException - if the container couldn't be started

getAwsProxyHandler

public static MicronautLambdaContainerHandler getAwsProxyHandler(io.micronaut.context.ApplicationContextBuilder builder)
                                                          throws com.amazonaws.serverless.exceptions.ContainerInitializationException

Gets a new MicronautLambdaContainerHandler should be called exactly once.

Parameters:

builder - The builder to customize the context creation

Returns:

The MicronautLambdaContainerHandler

Throws:

com.amazonaws.serverless.exceptions.ContainerInitializationException - if the container couldn't be started

getApplicationContext

public io.micronaut.context.ApplicationContext getApplicationContext()

Specified by:

getApplicationContext in interface io.micronaut.context.ApplicationContextProvider

Returns:

The underlying application context

objectMapper

protected com.fasterxml.jackson.databind.ObjectMapper objectMapper()

Description copied from class: AbstractLambdaContainerHandler

The object mapper.

Specified by:

objectMapper in class AbstractLambdaContainerHandler<com.amazonaws.serverless.proxy.model.AwsProxyRequest,com.amazonaws.serverless.proxy.model.AwsProxyResponse,MicronautAwsProxyRequest<?>,MicronautAwsProxyResponse<?>>

Returns:

Return the object mapper.

writerFor

protected com.fasterxml.jackson.databind.ObjectWriter writerFor(java.lang.Class<com.amazonaws.serverless.proxy.model.AwsProxyResponse> responseClass)

Description copied from class: AbstractLambdaContainerHandler

Gets a writer for the given response class.

Specified by:

writerFor in class AbstractLambdaContainerHandler<com.amazonaws.serverless.proxy.model.AwsProxyRequest,com.amazonaws.serverless.proxy.model.AwsProxyResponse,MicronautAwsProxyRequest<?>,MicronautAwsProxyResponse<?>>

Parameters:

responseClass - The response class

Returns:

The writer

readerFor

protected com.fasterxml.jackson.databind.ObjectReader readerFor(java.lang.Class<com.amazonaws.serverless.proxy.model.AwsProxyRequest> requestClass)

Description copied from class: AbstractLambdaContainerHandler

Gets a reader for the given request class.

Specified by:

readerFor in class AbstractLambdaContainerHandler<com.amazonaws.serverless.proxy.model.AwsProxyRequest,com.amazonaws.serverless.proxy.model.AwsProxyResponse,MicronautAwsProxyRequest<?>,MicronautAwsProxyResponse<?>>

Parameters:

requestClass - The request class

Returns:

The reader

getContainerResponse

protected MicronautAwsProxyResponse<?> getContainerResponse(MicronautAwsProxyRequest<?> request,
                                                            java.util.concurrent.CountDownLatch latch)

Description copied from class: AbstractLambdaContainerHandler

Get the container response.

Specified by:

getContainerResponse in class AbstractLambdaContainerHandler<com.amazonaws.serverless.proxy.model.AwsProxyRequest,com.amazonaws.serverless.proxy.model.AwsProxyResponse,MicronautAwsProxyRequest<?>,MicronautAwsProxyResponse<?>>

Parameters:

request - The request

latch - The count down latch

Returns:

The response

initialize

public void initialize()
                throws com.amazonaws.serverless.exceptions.ContainerInitializationException

Description copied from class: AbstractLambdaContainerHandler

Initialize the container.

Specified by:

initialize in class AbstractLambdaContainerHandler<com.amazonaws.serverless.proxy.model.AwsProxyRequest,com.amazonaws.serverless.proxy.model.AwsProxyResponse,MicronautAwsProxyRequest<?>,MicronautAwsProxyResponse<?>>

Throws:

com.amazonaws.serverless.exceptions.ContainerInitializationException - when an error occurs

handleRequest

protected void handleRequest(MicronautAwsProxyRequest<?> containerRequest,
                             MicronautAwsProxyResponse<?> containerResponse,
                             com.amazonaws.services.lambda.runtime.Context lambdaContext)

Description copied from class: AbstractLambdaContainerHandler

Handle the request.

Specified by:

handleRequest in class AbstractLambdaContainerHandler<com.amazonaws.serverless.proxy.model.AwsProxyRequest,com.amazonaws.serverless.proxy.model.AwsProxyResponse,MicronautAwsProxyRequest<?>,MicronautAwsProxyResponse<?>>

Parameters:

containerRequest - The container request

containerResponse - The response

lambdaContext - The lambda context

close

public void close()

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable