in aws-globalaccelerator-listener/src/main/kotlin/software/amazon/globalaccelerator/listener/ListHandler.kt [18:33]
override fun handleRequest(proxy: AmazonWebServicesClientProxy,
request: ResourceHandlerRequest<ResourceModel>,
callbackContext: CallbackContext?,
logger: Logger): ProgressEvent<ResourceModel, CallbackContext?> {
logger.debug("List Listeners Request: $request")
val agaClient = client
val model = request.desiredResourceState
val listListenersRequest = ListListenersRequest().withAcceleratorArn(model.acceleratorArn).withNextToken(request.nextToken)
val listListenersResult = proxy.injectCredentialsAndInvoke(listListenersRequest, agaClient::listListeners)
val listenerList = convertListenerList(listListenersResult.listeners, model.acceleratorArn)
return ProgressEvent.builder<ResourceModel, CallbackContext>()
.status(OperationStatus.SUCCESS)
.resourceModels(listenerList)
.nextToken(listListenersResult.nextToken)
.build()
}