Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

When manual SqsMessageListenerContainer do not shutdown in sample #840

Closed
xyzlast opened this issue Jun 22, 2023 · 0 comments
Closed

When manual SqsMessageListenerContainer do not shutdown in sample #840

xyzlast opened this issue Jun 22, 2023 · 0 comments

Comments

@xyzlast
Copy link

xyzlast commented Jun 22, 2023

Type: Bug

Component: SQS

SqsMessageListenerContainer cannot finish in 20 seconds.

Sample

Here is my configuration

@Slf4j
@Configuration
@EnableAsync(proxyTargetClass = true)
public class AdminMqConfig {
    @Bean
    public MessageListenerContainer<Object> manualPushMessageListenerContainer(SqsAsyncClient sqsAsyncClient) {
        return SqsMessageListenerContainer.builder()
            .sqsAsyncClient(sqsAsyncClient)
            .messageListener(System.out::println)
            .queueNames("sqsName.fifo")
            .id("id")
            .build();
    }
}

and show shutdown error in console

2023-06-22T194143.780 WARN  --- [ i.a.c.s.l.s.AbstractPollingMessageSource ] Tasks did not finish in 20 seconds for queue sqsName, proceeding with shutdown
2023-06-22T194143.780 ERROR --- [ i.a.c.s.l.s.AbstractPollingMessageSource ] Error polling for messages in queue 
java.util.concurrent.CancellationException: null
	at java.base/java.util.concurrent.CompletableFuture.cancel(CompletableFuture.java:2510)
	at io.awspring.cloud.sqs.listener.source.AbstractPollingMessageSource.lambda$stop$6(AbstractPollingMessageSource.java:305)
	at java.base/java.util.ArrayList.forEach(ArrayList.java:1511)
	at java.base/java.util.Collections$SynchronizedCollection.forEach(Collections.java:2131)
	at io.awspring.cloud.sqs.listener.source.AbstractPollingMessageSource.stop(AbstractPollingMessageSource.java:305)
	at io.awspring.cloud.sqs.LifecycleHandler.lambda$manageLifecycle$4(LifecycleHandler.java:76)
	at java.base/java.util.Spliterators$ArraySpliterator.forEachRemaining(Spliterators.java:1006)
	at java.base/java.util.stream.ReferencePipeline$Head.forEach(ReferencePipeline.java:762)
	at io.awspring.cloud.sqs.LifecycleHandler.manageLifecycle(LifecycleHandler.java:74)
	at io.awspring.cloud.sqs.LifecycleHandler.lambda$manageLifecycle$0(LifecycleHandler.java:81)
	at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804)
	at java.base/java.lang.Thread.run(Thread.java:1589)
2023-06-22T194143.783 INFO  --- [ a.c.s.l.AbstractMessageListenerContainer ] Container sqsName stopped
@xyzlast xyzlast closed this as completed Jun 22, 2023
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

1 participant