Spring Cloud Contract 与 Spring AMQP

Question

所以我一直在尝试使用 Spring Cloud Contract 来测试 RabbitListener。

到目前为止，我发现通过在合同中定义“triggeredBy”，生成的测试将调用那里提供的方法，因此我们需要在 TestBase 中提供该方法的实际实现。 另一件事是“outputMessage”，在这里我们可以验证之前的方法调用是否正确地导致了一些消息体发送到某个交换。

来源：documentation 和 sample

我的问题是，有没有办法从合约中生成输入消息，而不是触发自己的自定义方法？ 可能类似于文档中的 Spring Integration 或 Spring Cloud Stream 示例：

Contract.make {
    name("Book Success")
    label("book_success")
    input {
        messageFrom 'input.exchange.and.maybe.route'
        messageHeaders {
            header('contentType': 'application/json')
            header('otherMessageHeader': '1')
        }
        messageBody ([
                bookData: someData
        ])
    }
    outputMessage {
        sentTo 'output.exchange.and.maybe.route'
        headers {
            header('contentType': 'application/json')
            header('otherMessageHeader': '2')
        }
        body([
                bookResult: true
        ])
    }
}

我在他们的示例项目中找不到任何示例来说明如何执行此操作。

使用 Spring Cloud Contract 来记录和测试 rest api 服务，如果可能的话，我希望通过在基于事件的服务的合同文件中定义输入和预期输出来保持一致。

Answer 1

没关系，实际上它已经被支持了。 由于未知原因，"Stub Runner Spring AMQP" 中的文档没有像之前的示例一样列出场景。

这是我的工作方式：

    Contract.make {
        name("Amqp Contract")
        label("amqp_contract")
        input {
            messageFrom 'my.exchange'
            messageHeaders {
                header('contentType': 'text/plain')
                header('amqp_receivedRoutingKey' : 'my.routing.key')
            }
            messageBody(file('request.json'))
        }
        outputMessage {
            sentTo 'your.exchange'
            headers {
                header('contentType': 'text/plain')
                header('amqp_receivedRoutingKey' : 'your.routing.key')
            }
            body(file('response.json'))
        }
    }

这将创建一个测试，该测试将根据触发处理程序方法的“my.exchange”和“my.routing.key”调用您的侦听器。 然后它会在你的 RabbitTemplate 调用“your.exchange”时捕获消息和路由键。

    verify(this.rabbitTemplate, atLeastOnce()).send(eq(destination), routingKeyCaptor.capture(),
            messageCaptor.capture(), any(CorrelationData.class));

然后消息和路由键都将被断言。