VertxLambdaHandler.groovy

@SpringBootApplication
@ComponentScan
@Log4j
class VertxLambdaHandler implements RequestHandler<Map, Response> {

  static void main(String[] args) throws Exception {
    LambdaHandler.newInstance().getApplicationContext(args)
  }

  @Memoized
  ApplicationContext getApplicationContext(String[] args = []) {
    return SpringApplication.run(LambdaHandler.class, args)
  }

  @Override
  Response handleRequest(Map input, Context context) {
    final Request request = new Request(context.awsRequestId, input)
    def eventBus = applicationContext.getBean(EventBus.class)
    
    CompletableFuture<Response> future = new CompletableFuture<>()
    eventBus.send(request.methodResource(), request, { ar ->
      if (ar.succeeded()) {
        assert ar.result().body() instanceof Response
        log.info "Received reply: ${ar.result().body()}"
        future.complete(ar.result().body())
      }
    })
    
    future.get(5, TimeUnit.SECONDS)
  }
}