Spring集成-使用Java配置转换服务激活器

Question

我试图从Spring集成示例中转换“Hello World示例”(https://github.com/spring-projects/spring-integration-samples/tree/master/basic/helloworld)从XML到Java配置（使用@Configuration注释也是如此）。

配置类如下所示：

@Configuration
@EnableIntegration
public class BasicIntegrationConfig{

    @Bean
    public DirectChannel inputCHannel() {
        return new DirectChannel();
    }

    @Bean
    public QueueChannel outputChannel() {
        return new QueueChannel();
    }

    @Bean
    @ServiceActivator(inputChannel= "inputChannel", outputChannel= "outputChannel" )
    public MessageHandler fileWritingMessageHandler() {
        MessageHandler mh =  new MessageHandler() {
            @Override
            public void handleMessage(Message<?> message) throws MessagingException {
                System.out.println("Message payload: " + message.getPayload());
            }
        };
        return mh;
    }
}

为了测试它，我使用示例项目提供的main（）：

DirectChannel fileChannel = applicationContext.getBean("inputChannel", DirectChannel.class);
QueueChannel outputChannel = applicationContext.getBean("outputChannel", QueueChannel.class);
System.out.println("********** SENDING MESSAGE");
fileChannel.send(new GenericMessage<>("test"));
System.out.println(outputChannel.receive(0).getPayload());

我在控制台中看到“Message payload:test”，但不幸的是，我没有在outputchannel上接收消息（我在outputchannel.receive（0）上有一个NullPointerException）。您知道为什么Service Activator不将消息发送到输出通道吗？

Answer 1

谢谢你，加里，切换到以下位置后效果很好：

    @Bean
    @ServiceActivator(inputChannel= "inputChannel")
    public AbstractReplyProducingMessageHandler fileWritingMessageHandler() {
        AbstractReplyProducingMessageHandler  mh = new AbstractReplyProducingMessageHandler() {
            @Override
            protected Object handleRequestMessage(Message<?> message) {
                String payload= (String)message.getPayload();
                return "Message Payload : ".concat(payload);
            }
        };
        mh.setOutputChannelName("outputChannel");
        return mh;
    }

作为旁注，我必须删除@ServiceActivator注释中的输出通道属性，并将其放在方法体中（如果没有，则为Bean验证异常）。

Answer 2

你的MessageHandler返回void。

您需要子类AbstractReplyProducingMessageHandler来代替。