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

Constructor Summary

Constructors

Constructor and Description
MicronautLambdaContainerHandler() Default constructor.
MicronautLambdaContainerHandler(io.micronaut.context.ApplicationContext applicationContext) Constructor used to inject a preexisting ApplicationContext.
MicronautLambdaContainerHandler(io.micronaut.context.ApplicationContextBuilder applicationContextBuilder) Default constructor.

Method Summary

Modifier and Type	Method and Description
protected void	addByteArrayToStringConverter() Adds a converter from byte array to string.
protected void	addConverters() Add converters to the Application environment.
void	close()
io.micronaut.context.ApplicationContext	getApplicationContext()
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.
protected void	initContainerState()
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

Constructor Detail

MicronautLambdaContainerHandler

public MicronautLambdaContainerHandler(io.micronaut.context.ApplicationContextBuilder applicationContextBuilder)
                                throws com.amazonaws.serverless.exceptions.ContainerInitializationException

Default constructor.

Parameters:

applicationContextBuilder - The context builder

Throws:

com.amazonaws.serverless.exceptions.ContainerInitializationException - The exception

MicronautLambdaContainerHandler

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

Default constructor.

Throws:

com.amazonaws.serverless.exceptions.ContainerInitializationException - The exception

MicronautLambdaContainerHandler

public MicronautLambdaContainerHandler(io.micronaut.context.ApplicationContext applicationContext)
                                throws com.amazonaws.serverless.exceptions.ContainerInitializationException

Constructor used to inject a preexisting ApplicationContext.

Parameters:

applicationContext - application context

Throws:

com.amazonaws.serverless.exceptions.ContainerInitializationException - The exception

Method Detail

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

initContainerState

protected void initContainerState()

addConverters

protected void addConverters()

Add converters to the Application environment.

addByteArrayToStringConverter

protected void addByteArrayToStringConverter()

Adds a converter from byte array to string.

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