in powertools-sqs/src/main/java/software/amazon/lambda/powertools/sqs/internal/SqsLargeMessageAspect.java [42:59]
public Object around(ProceedingJoinPoint pjp,
SqsLargeMessage sqsLargeMessage) throws Throwable {
Object[] proceedArgs = pjp.getArgs();
if (isHandlerMethod(pjp)
&& placedOnSqsEventRequestHandler(pjp)) {
List<PayloadS3Pointer> pointersToDelete = rewriteMessages((SQSEvent) proceedArgs[0]);
Object proceed = pjp.proceed(proceedArgs);
if (sqsLargeMessage.deletePayloads()) {
pointersToDelete.forEach(SqsLargeMessageAspect::deleteMessage);
}
return proceed;
}
return pjp.proceed(proceedArgs);
}