我可以从入站通道适配器处理程序中发送Spring Integration Channel消息吗？

Question

如果某些条件允许，我希望从我的文件入站通道适配器的处理程序中向另一个通道发送消息。有时入站文件有超出规范的值，我希望将该文件发送到错误目录，但不要中断入站到出站的流程，因为即使超出规范的文件也需要转到辅助位置。

我的配置示例：

<int-file:inbound-channel-adapter id="filesIn"
                                  directory="${input.path}"
                                  filename-regex="\\d{8}-\\d+\\.txt">
    <int:poller id="poller" fixed-rate="500"/>
</int-file:inbound-channel-adapter>

<int-file:file-to-string-transformer input-channel="filesIn"
                                     output-channel="strings"
                                     delete-files="true" />

<int:channel id="strings"/>
<int:channel id="errorChannel" />

<int:exception-type-router input-channel="strings"
                           default-output-channel="output">
    <int:mapping exception-type="ca.uhn.hl7v2.HL7Exception"
                 channel="errorChannel"/>
</int:exception-type-router>

<int:service-activator input-channel="output"
                               output-channel="archive"
                               ref="handler" method="handleString"/>

<int:service-activator input-channel="errorChannel"
                       output-channel="errorOutput"
                       ref="handler" method="handleError" />

<int-file:outbound-channel-adapter id="archive"
                                   directory="${archive.path}"
                                   delete-source-files="true"/>

<int-file:outbound-channel-adapter id="errorOutput"
                                   directory="${hl7.error.path}"/>

<bean id="handler" class="com.giotta.service.Hl7MessageConsumer"/>

Answer 1

从术语的角度来看，入站适配器没有“处理程序”。根据类型的不同，它们要么是消息源，要么是消息生产者。

也就是说，您可以在入站适配器之后立即添加路由器，并根据您想要的任何条件路由到不同的信道。

编辑

<int-file:inbound-channel-adapter id="filesIn"
                                  directory="${input.path}"
                                  filename-regex="\\d{8}-\\d+\\.txt">
    <int:poller id="poller" fixed-rate="500" error-channel="errorChannel" />
</int-file:inbound-channel-adapter>

<int-file:file-to-string-transformer input-channel="filesIn"
                                     output-channel="strings"
                                     delete-files="true" />

<int:channel id="strings"/>

<int:service-activator input-channel="strings"
                               output-channel="archive"
                               ref="handler" method="handleString"/>

<int-file:outbound-channel-adapter id="archive"
                                   directory="${archive.path}"
                                   delete-source-files="true"/>

<int:channel id="errorChannel" />

<int:service-activator input-channel="errorChannel"
                       output-channel="errorOutput"
                       ref="handler" method="handleError" />

<int-file:outbound-channel-adapter id="errorOutput"
                                   directory="${hl7.error.path}"/>

<bean id="handler" class="com.giotta.service.Hl7MessageConsumer"/>

除了“ErrorOutput”适配器之外，我仍然希望字符串转到“Archive”适配器。

那样的话...

<int:publish-subscribe-channel id="errorChannel" />

<int:service-activator input-channel="errorChannel"
                       output-channel="errorOutput"
                       ref="handler" method="handleError" />

<int:transformer input-channel="errorChannel"
            output-channel="archive" expression="payload.failedMessage" />