spring-cloud-aws
spring-cloud-aws copied to clipboard
The New Home for Spring Cloud AWS
**Type**: Bug **Component**: "S3", "SQS" **Describe the bug** I'm really facing up with S3 event lambda function deserialization. I'm getting: > ClassCastException: class org.springframework.util.LinkedMultiValueMap cannot be cast to class com.amazonaws.services.lambda.runtime.events.models.s3.S3EventNotification...
**Type**: Bug **Component**: SQS **Describe the bug** When using many SQS queues, and one of them does not exist, spring shows an error in all queues. And the error is...
**Type**: Bug **Component**: "SQS" **Describe the bug** I use two same consumers (potentially more) to distribute the requests among unique third-party license profiles. During the message processing, the consumer updates...
Currently in order to not add type information to messages sent with the `SqsTemplate` it's necessary to do something like this: ```java SqsTemplate template = SqsTemplate.builder().sqsAsyncClient(this.asyncClient) .configureDefaultConverter(converter -> converter.setPayloadTypeHeaderValueFunction(msg ->...
## :loudspeaker: Type of change - [ ] Bugfix - [ ] New feature - [x] Enhancement - [ ] Refactoring ## :scroll: Description #887 ## :bulb: Motivation and Context...
I tried to configure SqsMessageListenerContainerFactory to use VirtualThreadTaskExecutor: ```java @Bean SqsMessageListenerContainerFactory defaultSqsListenerContainerFactory(SqsAsyncClient sqsAsyncClient) { return SqsMessageListenerContainerFactory.builder() .configure(options -> options.componentsTaskExecutor( new VirtualThreadTaskExecutor("sqs-message-listener-container-components-")) .acknowledgementResultTaskExecutor(new VirtualThreadTaskExecutor( "sqs-message-listener-container-acknowledgement-result-"))) .sqsAsyncClient(sqsAsyncClient) .build(); } ``` But this...
https://github.com/awspring/spring-cloud-aws/issues/971 Clarify bean factory name overrides needed for a mix of @SqsListener acknowledgmentMode usages with existing custom MessageListenerContainerFactory defined in the app. ## :loudspeaker: Type of change - [ ]...
…fail to start rather than throwing endless Executor errors. ## :loudspeaker: Type of change - [ ] Bugfix - [ ] New feature - [ ] Enhancement - [x] Refactoring...
**Type**: Feature **Is your feature request related to a problem? Please describe.** If 1 of the 10 messages fails, only the failing message should be put back in the queue,...
**Type**: Bug **Component**: **Describe the bug** Here my configuration: ```java @Configuration @EnableConfigurationProperties({ AppProperties.class }) @RequiredArgsConstructor @Slf4j public class AppConfiguration { private final AppProperties appProperties; @Bean MessageListenerContainer listenerContainer(SqsAsyncClient sqsAsyncClient, SQSS3CreatedNotificationService sqsS3CreatedNotificationService)...