如何使用 Spring Integration 从 Java bean 正确创建 RabbitMQ 自定义消息？

Question

我是 Spring Integration 的新手，也许这个问题是微不足道的。我正在查看示例 (https://github.com/spring-projects/spring-integration-samples/tree/master/basic/amqp) 从标准输入创建 RabbitMq 消息：

<int-stream:stdin-channel-adapter id="consoleIn"
    channel="toRabbit">
    <int:poller fixed-delay="1000" max-messages-per-poll="1" />
</int-stream:stdin-channel-adapter>
<int:channel id="toRabbit" />
<int-amqp:outbound-channel-adapter
    channel="toRabbit" amqp-template="amqpTemplate"
    exchange-name-expression="payload.toLowerCase() == 'nack' ? 'badExchange' : 'si.test.exchange'"
    routing-key-expression="payload.toLowerCase() == 'fail' ? 'badKey' : 'si.test.binding'"
    confirm-correlation-expression="payload"
    confirm-ack-channel="good"
    confirm-nack-channel="errors"
    return-channel="returns" />

如果我们需要使用 Java 代码生成自定义消息怎么办。什么是适当的优雅代码？填充消息的 bean 被简化：

package com.mycompany.domain.price;    
public class UpdateMessage implements Serializable {
Date effStartDate;
Date effEndDate;
Long orderId = -1;
String customerFullName;
...
}

Answer 1

见this answer;虽然它是在谈论 Axis 而不是 RabbitMQ；同样的技术也适用。

由于您的UpdateMessage 实现了Serializable，标准消息转换器将为您处理转换为byte[]。

发送没有回复的消息，你的网关接口方法可能是

public void send(UpdateMessage msg);

在这种情况下，您会使用出站通道适配器。如果您想得到回复，请使用 amqp 出站网关，服务接口可能如下所示

public UpdateResult send(UpdateMessage msg);

如果您不使用 Serializable 对象，则可能适合使用 json 转换器。