如果我不想用dsl来编写在jms和spring集成通道之间建立连接的代码，该怎么做呢

Question

@Bean
public IntegrationFlow outboundFlow(ActiveMQConnectionFactory connectionFactory) {
    return IntegrationFlows
            .from(requests())
            .handle(Jms.outboundAdapter(connectionFactory).destination("requests"))
            .get();
}

Answer 1

jms.outboundAdapter(connectionFactory)是围绕JMSSendingMessageHandler的语法糖分包装器。

.handle()与@ServiceActivator等效。

因此，您需要的普通Java如下所示：

@Bean
@ServiceActivator(inputChannel="requests")
public MessageHandler jmsMessageHandler((ActiveMQConnectionFactory connectionFactory) {
   JmsSendingMessageHandler handler = new JmsSendingMessageHandler(new JmsTemplate(connectionFactory));
   handler.setDestinationName("requests");
   return handler;
}