mule vm:未触发入口 - 端点

Question

我有一个要在类似器中处理的列表，因此在调用collection-splitter后，我将每个记录发布到出站端点，但是未触发接收的入站 - 端点。以下配置;

<flow name="ProcessPolledOrders" doc:name="ProcessPolledOrders">
        <set-session-variable variableName="fileName" value="#[message.payload.orderBatch.orderSourceName]" />
        <set-session-variable variableName="batchId" value="#[message.payload.orderBatch.id]" />
        <logger message="************* Item: #[sessionVars.fileName] processing resumed. ***********" level="INFO"/>
        <component>
            <spring-object bean="PolledOrderSplitter"/>
        </component>
        <set-session-variable variableName="size" value="#[message.payload.size()"/>
        <collection-splitter/>
        <set-property propertyName="MULE_CORRELATION_GROUP_SIZE" value="#[sessionVars.size]" />
        <set-property propertyName="MULE_CORRELATION_ID" value="#[sessionVars.fileName]" />
        <choice>
            <when>
                <payload-type-filter expectedType="model.Order"/>
                <vm:outbound-endpoint exchange-pattern="one-way" path="step2" doc:name="VM"/>
            </when>
            <otherwise>
                <echo-component/>
            </otherwise>
        </choice>
    </flow>
<flow name="PollerOrderProcessingFlow" doc:name="PollerOrderProcessingFlow">
        <vm:inbound-endpoint exchange-pattern="one-way" path="step2" doc:name="VM"/>
        <logger message="***************** Validating order with id #[message.payload.id] ********************"
                level="INFO"/>
        <component>
            <spring-object bean="PolledOrderValidationComponent"/>
        </component>
        <collection-aggregator timeout="600000" failOnTimeout="false"
                               doc:name="Validated Orders Aggregator"/>
        <component>
            <spring-object bean="BatchOrderUpdateComponent"/>
        </component>
        <default-exception-strategy>
            <flow-ref name="ValidationProcessingExceptionFlow" />
        </default-exception-strategy>
    </flow>

Answer 1

您是否得到任何例外？尝试调试并查看消息下降的位置？我尝试了类似的流程，对我来说正常工作。