测试spring cloud SQS Listener的问题

Question

null

我正在尝试为SQS编写一个集成测试。

我有一个本地运行的localstack docker容器，其中SQS在TCP/4576上运行

在我的测试代码中，我定义了一个endpoint设置为Local4576的SQS客户机，它可以成功地连接和创建队列、发送消息和删除队列。我还可以使用SQS客户机接收消息并拾取我发送的消息。

我的问题是，如果我为了允许另一个组件获得消息而删除了正在手动接收消息的代码，似乎什么也不会发生。我有一个spring组件注释如下：

@Component
public class MyListener {
@SqsListener(value = "my_queue", deletionPolicy = ON_SUCCESS)
    public void receive(final MyMsg msg) {
        System.out.println("GOT THE MESSAGE: "+ msg.toString());
    }
}

@RunWith(SpringRunner.class)
@SpringBootTest(properties = "spring.profiles.active=test")
public class MyTest {

    @Autowired
    private AmazonSQSAsync amazonSQS;

    @Autowired
    private SimpleMessageListenerContainer container;

    private String queueUrl;

    @Before
    public void setUp() {
        queueUrl = amazonSQS.createQueue("my_queue").getQueueUrl();
    }

    @After
    public void tearDown() {
        amazonSQS.deleteQueue(queueUrl);
    }

    @Test
    public void name() throws InterruptedException {
        amazonSQS.sendMessage(new SendMessageRequest(queueUrl, "hello"));
        System.out.println("isRunning:" + container.isRunning());
        System.out.println("isActive:" + container.isActive());
        System.out.println("isRunningOnQueue:" + container.isRunning("my_queue"));
        Thread.sleep(30_000);
        System.out.println("GOT MESSAGE: " + amazonSQS.receiveMessage(queueUrl).getMessages().size());
    }

    @TestConfiguration
    @EnableSqs
    public static class SQSConfiguration {

        @Primary
        @Bean(destroyMethod = "shutdown")
        public AmazonSQSAsync amazonSQS() {
            final AwsClientBuilder.EndpointConfiguration endpoint = new AwsClientBuilder.EndpointConfiguration("http://127.0.0.1:4576", "eu-west-1");
            return new AmazonSQSBufferedAsyncClient(AmazonSQSAsyncClientBuilder
                    .standard()
                    .withCredentials(new AWSStaticCredentialsProvider(new BasicAWSCredentials("key", "secret")))
                    .withEndpointConfiguration(endpoint)
                    .build());
        }
    }
}

在我看到的测试日志中：

O.S.C.A.M.Listener.QueueMessageHandler：在类MyListener上找到1个消息处理程序方法：{public void MyListener.Receive(MyMsg)=org.SpringFramework.Cloud.aws.Messaging.Listener.QueueMessageHandler$MappingInformation@1CD4082A}2018-05-31 22:50:39.582 INFO 16329---

O.S.C.A.M.Listener.QueueMessageHandler：将“org.springframework.cloud.aws.messaging.listener.QueueMessageHandler$MappingInformation@1CD4082A”映射到公共void MyListener.Receive（MyMsg）

紧随其后的是：

ISRunning：True

ISActive：True

我还设置了

logging.level.org.apache.http=DEBUG
logging.level.org.springframework.cloud=DEBUG

在我的测试属性中，可以看到HTTP调用创建队列、发送消息和删除等，但没有HTTP调用要接收（除了我在测试结束时的手动调用）。

Answer 1

我是在修修补补之后才想出来的。

即使简单的消息容器工厂被设置为不自动启动，它似乎也会进行初始化，这涉及到确定队列是否存在。

在本例中，队列是在setup方法中在我的测试中创建的--但遗憾的是，这是在spring上下文设置之后，这意味着发生了异常。

@Bean(destroyMethod = "shutdown")
        public AmazonSQSAsync amazonSQS() {
            final AwsClientBuilder.EndpointConfiguration endpoint = new AwsClientBuilder.EndpointConfiguration("http://localhost:4576", "eu-west-1");
            final AmazonSQSBufferedAsyncClient client = new AmazonSQSBufferedAsyncClient(AmazonSQSAsyncClientBuilder
                    .standard()
                    .withCredentials(new AWSStaticCredentialsProvider(new BasicAWSCredentials("dummyKey", "dummySecret")))
                    .withEndpointConfiguration(endpoint)
                    .build());
            client.createQueue("test-queue");
            return client;
        }