Spring云合同与Spring AMQP

Question

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

资料来源：文件和样本

我的问题是，有没有办法从契约中产生输入消息，而不是触发自己的自定义方法？文档中的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服务之后，如果可能的话，我希望通过在基于事件的服务的contract文件中定义输入和预期输出来保持一致。

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));