java - Spring 集成: Dispatcher has no subscribers for channel

Question

我正在尝试构建一个 Spring 集成应用程序，它具有以下配置(罪魁祸首似乎是 channel xsltSpecific):

<beans:beans>   
    <channel id="channel1"></channel>
    <channel id="channel2"></channel>
    <channel id="xsltSpecific"></channel>
    <channel id="xsltSpecificDelayed"></channel>
    <channel id="xsltCommon"></channel>
    <channel id="irdSpecificUnmarshallerChannel"></channel>
    <channel id="irdSpecificInputChannel"></channel>

    <file:outbound-channel-adapter
        directory="${dml.ird.directory}" channel="channel1"
        auto-create-directory="true" filename-generator="timestampedFileNameGenerator">
    </file:outbound-channel-adapter>

    <recipient-list-router input-channel="fileChannel">
        <recipient channel="channel1" selector-expression="${dml.data.logs.enable}" />
        <recipient channel="channel2" />
    </recipient-list-router>
    <recipient-list-router input-channel="channel2">
        <recipient channel="xsltSpecificDelayed"></recipient>
        <recipient channel="xsltCommon"></recipient>
    </recipient-list-router>

    <delayer id="specificDelayer" input-channel="xsltSpecificDelayed" default-delay="5000" output-channel="xsltSpecific"/>

    <jms:message-driven-channel-adapter
        id="jmsInboundAdapterIrd" destination="jmsInputQueue" channel="fileChannel"
        acknowledge="transacted" transaction-manager="transactionManager"
        error-channel="errorChannel" client-id="${ibm.jms.connection.factory.client.id}"
        subscription-durable="true" durable-subscription-name="${ibm.jms.subscription.id1}" />

    <si-xml:xslt-transformer input-channel="xsltCommon" output-channel="jmsInputChannel"
        xsl-resource="classpath:summit-hub-to-cpm-mapping.xsl" result-transformer="resultTransformer" >
    </si-xml:xslt-transformer>

    <si-xml:xslt-transformer input-channel="xsltSpecific" output-channel="irdSpecificUnmarshallerChannel"
        xsl-resource="classpath:summit-hub-specific.xsl" result-transformer="resultTransformer" >
    </si-xml:xslt-transformer>

    <si-xml:unmarshalling-transformer id="irdUnmarshaller"
        unmarshaller="irdUnmarshallerDelegate" input-channel="irdSpecificUnmarshallerChannel"
        output-channel="saveSpecificTradeChannel" />

    <beans:bean id="irdUnmarshallerDelegate"
        class="org.springframework.oxm.jaxb.Jaxb2Marshaller">
        <beans:property name="schema"
            value="summit-hub-specific.xsd" />
        <beans:property name="contextPath"
            value="com.h.i.c.d.i.mapping" />
    </beans:bean>

    <beans:bean id="resultTransformer" class="org.springframework.integration.xml.transformer.ResultToStringTransformer" />

    <service-activator ref="specificTradeService" input-channel="saveSpecificTradeChannel" 
        requires-reply="false" method="save"/>

    <file:inbound-channel-adapter directory="${dml.retry.directoryForIrd}"
        channel="fileChannelAfterRetry" auto-create-directory="true"
        prevent-duplicates="false" filename-regex=".*\.(msg|xml)" queue-size="50" >
        <poller fixed-delay="${dml.retry.delay}" max-messages-per-poll="50">
            <transactional transaction-manager="transactionManager" />
        </poller>
    </file:inbound-channel-adapter>

    <channel id="fileChannel"/>
    <channel id="fileChannelAfterRetry"/>

    <file:file-to-string-transformer
        input-channel="fileChannelAfterRetry" output-channel="fileChannel"
        delete-files="true" />

    <beans:import resource="classpath:cpm-dml-common-main.xml" />
</beans:beans>

但我有以下异常(exception):

org.springframework.messaging.MessageDeliveryException: Dispatcher has no subscribers for channel 'org.springframework.context.support.GenericApplicationContext@6950e31.xsltSpecific'.; nested exception is org.springframework.integration.MessageDispatchingException: Dispatcher has no subscribers

这个异常是什么意思？ 另外，我无法发现问题，你能帮我解决这个问题吗？

更新

抱歉，我之前没有提供完整的上下文，因为我认为它不相关。 在从 AbstractTransactionalJUnit4SpringContextTests 派生的测试期间出现异常，该测试在测试结束时、消息有机会到达末尾之前关闭了应用程序上下文。 我在测试结束时添加了 Thread.sleep(10000) ，并且不再发生异常。

Answer 1

xsltSpecific 只是一个默认的 DirectChannel，带有 UnicastingDispatcher，用于向 channel 的订阅者传递消息。

根据您的配置，您从以下位置向此 channel 发送消息:

<delayer id="specificDelayer" input-channel="xsltSpecificDelayed" default-delay="5000" output-channel="xsltSpecific"/>

而且您似乎确实有此 channel 的订阅者:

<si-xml:xslt-transformer input-channel="xsltSpecific" output-channel="irdSpecificUnmarshallerChannel"
    xsl-resource="classpath:summit-hub-specific.xsl" result-transformer="resultTransformer" >
</si-xml:xslt-transformer>

当这个定义的订阅者丢失时，真的不清楚什么。看起来您在此端点上没有 auto-startup="false" ，但另一方面，也许您确实在运行时停止了它...

您介意分享更多有关此事的堆栈跟踪吗？我想看看谁是丢失消息的原始调用者。