Spring集成不转换字节消息

Question

我有一个JMS侦听器，它正在从另一个应用程序接收字节消息。当前应用程序正在使用Spring JMS。我想在这里介绍spring集成。因此，我添加了以下示例代码来侦听消息。

@Configuration
public class JmsConfiguration {

@Bean
public IntegrationFlow integrationFlow(ConnectionFactory connectionFactory) {

    return IntegrationFlows
            .from(Jms.messageDrivenChannelAdapter(connectionFactory)
                    .destination("fooQueue"))
                    .transform("hello "::concat)
                    .get();
}

然后我得到如下类强制转换异常：

java.lang.ClassCastException: [B cannot be cast to java.lang.String

我得到了一个ByteMessage，但我没有找到一个关于如何提取带有字节数组有效负载的ByteMessage的好例子。我是Spring集成世界的新手。

Answer 1

添加。转换（Transformers.objectToString（））在之前。transform（）ByteMessage将生成一条带有byte[]有效载荷的消息，因此在尝试连接它之前，需要将其转换为字符串。