代码之家 › 专栏 › 技术社区 › Johan

将org.springframework.amqp.support.converter.MessageConverter转换为org.springframework.messaging.converter.MessageConverter

spring-rabbitmq spring-amqp spring-cloud spring-boot java

0

Johan · 技术社区 · 6 年前

我有个习惯 org.springframework.amqp.support.converter.MessageConverter 编写供使用 spring-amqp 但现在我们要搬到 spring cloud stream 使用另一个消息转换器( org.springframework.messaging.converter.MessageConverter )

那么有没有办法从spring amqp消息转换器转换成( org.springframework.amqp.support.converter.MessageConverter网站 )到一个spring云流消息转换器( org.springframework.messaging.converter.messageconverter版本 )?

如果不是,有没有办法在 org.springframework.amqp.core.Message 到A org.springframework.messaging.Message 反之亦然,以便我可以重用为spring amqp编写的客户消息转换器?

1 回复 | 直到 6 年前

1

Gary Russell 6 年前

你的定制是什么性质的?

在spring cloud stream中,在消费者端,amqp消息已经转换为消息 Message<?> 在咨询转换器以转换 byte[] 有效载荷(amqp消息 body() )到所需的类型。

MessageProperties 被映射到 消息<?gt; 标题。

在出站端,转换器必须创建 字节[] 有效载荷。

scst中的转换器独立于传输(rabbitmq、kafka等),因此您可以在不重写任何代码的情况下更改绑定器。

因此,您需要将逻辑移植到消息传递转换器。