|
26 | 26 | import io.awspring.cloud.sqs.support.resolver.AcknowledgmentHandlerMethodArgumentResolver;
|
27 | 27 | import io.awspring.cloud.sqs.support.resolver.BatchAcknowledgmentArgumentResolver;
|
28 | 28 | import io.awspring.cloud.sqs.support.resolver.BatchPayloadMethodArgumentResolver;
|
| 29 | +import java.lang.annotation.Annotation; |
| 30 | +import java.lang.reflect.Method; |
| 31 | +import java.util.ArrayList; |
| 32 | +import java.util.Arrays; |
| 33 | +import java.util.Collection; |
| 34 | +import java.util.Collections; |
| 35 | +import java.util.HashSet; |
| 36 | +import java.util.List; |
| 37 | +import java.util.Map; |
| 38 | +import java.util.concurrent.atomic.AtomicInteger; |
| 39 | +import java.util.stream.Collectors; |
| 40 | +import java.util.stream.Stream; |
| 41 | +import java.util.stream.StreamSupport; |
29 | 42 | import org.springframework.aop.support.AopUtils;
|
30 | 43 | import org.springframework.beans.BeansException;
|
31 | 44 | import org.springframework.beans.factory.BeanFactory;
|
|
57 | 70 | import org.springframework.util.Assert;
|
58 | 71 | import org.springframework.util.StringUtils;
|
59 | 72 |
|
60 |
| -import java.lang.annotation.Annotation; |
61 |
| -import java.lang.reflect.Method; |
62 |
| -import java.util.ArrayList; |
63 |
| -import java.util.Arrays; |
64 |
| -import java.util.Collection; |
65 |
| -import java.util.Collections; |
66 |
| -import java.util.HashSet; |
67 |
| -import java.util.List; |
68 |
| -import java.util.Map; |
69 |
| -import java.util.concurrent.atomic.AtomicInteger; |
70 |
| -import java.util.stream.Collectors; |
71 |
| -import java.util.stream.Stream; |
72 |
| -import java.util.stream.StreamSupport; |
73 |
| - |
74 | 73 | /**
|
75 | 74 | * {@link BeanPostProcessor} implementation that scans beans for a {@link SqsListener @SqsListener} annotation, extracts
|
76 | 75 | * information to a {@link SqsEndpoint}, and registers it in the {@link EndpointRegistrar}.
|
|
0 commit comments