Я не могу создать прослушиватель очереди работ с помощью Spring Boot и SQS (сообщение отправляется и отображается в пользовательском интерфейсе SQS)
@MessageMapping
или @SqsListener
не работают
Java: 11
Spring Boot: 2.1.7
Зависимость: spring-cloud-aws-messaging
Это мой конфиг
@Configuration
@EnableSqs
public class SqsConfig {
@Value("#{'${env.name:DEV}'}")
private String envName;
@Value("${cloud.aws.region.static}")
private String region;
@Value("${cloud.aws.credentials.access-key}")
private String awsAccessKey;
@Value("${cloud.aws.credentials.secret-key}")
private String awsSecretKey;
@Bean
public Headers headers() {
return new Headers();
}
@Bean
public MessageQueue queueMessagingSqs(Headers headers,
QueueMessagingTemplate queueMessagingTemplate) {
Sqs queue = new Sqs();
queue.setQueueMessagingTemplate(queueMessagingTemplate);
queue.setHeaders(headers);
return queue;
}
private ResourceIdResolver getResourceIdResolver() {
return queueName -> envName + "-" + queueName;
}
@Bean
public DestinationResolver destinationResolver(AmazonSQSAsync amazonSQSAsync) {
DynamicQueueUrlDestinationResolver destinationResolver = new DynamicQueueUrlDestinationResolver(
amazonSQSAsync,
getResourceIdResolver());
destinationResolver.setAutoCreate(true);
return destinationResolver;
}
@Bean
public QueueMessagingTemplate queueMessagingTemplate(AmazonSQSAsync amazonSQSAsync,
DestinationResolver destinationResolver) {
return new QueueMessagingTemplate(amazonSQSAsync, destinationResolver, null);
}
@Bean
public QueueMessageHandlerFactory queueMessageHandlerFactory() {
QueueMessageHandlerFactory factory = new QueueMessageHandlerFactory();
MappingJackson2MessageConverter messageConverter = new MappingJackson2MessageConverter();
messageConverter.setStrictContentTypeMatch(false);
factory.setArgumentResolvers(Collections.singletonList(new PayloadArgumentResolver(messageConverter)));
return factory;
}
@Bean
public SimpleMessageListenerContainerFactory simpleMessageListenerContainerFactory(AmazonSQSAsync amazonSqs) {
SimpleMessageListenerContainerFactory factory = new SimpleMessageListenerContainerFactory();
factory.setAmazonSqs(amazonSqs);
factory.setMaxNumberOfMessages(10);
factory.setWaitTimeOut(2);
return factory;
}
}
Я также заметил, что org.springframework.cloud.aws.messaging.config.SimpleMessageListenerContainerFactory
и org.springframework.cloud.aws.messaging.config.annotation.SqsConfiguration
запускаются при запуске
И мой тест
@RunWith(SpringJUnit4ClassRunner.class)
public class ListenTest {
@Autowired
private MessageQueue queue;
private final String queueName = "test-queue-receive";
private String result = null;
@Test
public void test_listen() {
// given
String data = "abc";
// when
queue.send(queueName, data).join();
// then
Awaitility.await()
.atMost(10, TimeUnit.SECONDS)
.until(() -> Objects.nonNull(result));
Assertions.assertThat(result).equals(data);
}
@MessageMapping(value = queueName)
public void receive(String data) {
this.result = data;
}
}
Вы думаете, что что-то не так?
Я создаю репо, например: (https://github.com/mmaryo/java-sqs-test)
В папке test измените учетные данные aws в application.yml.
Затем запустите тесты.
@MessageMapping(value = queueName)
очередь не слушают? - person Maryo   schedule 25.08.2019@SqsListener
. - person chrylis -cautiouslyoptimistic-   schedule 25.08.2019SqsListener sqsListenerAnnotation = AnnotationUtils.findAnnotation(method, SqsListener.class);
всегда пусто. Таким образом, Spring dot не сканирует @Sqs в @SpringBootTest и не сканирует также в @Compent - person Maryo   schedule 27.08.2019