Mule：進程表達式求值程序

Question

我正在嘗試在我的流程中使用表達式#[process:processName:valueToProcess]。

這是我的流程配置：

<flow name="exampleFlow"> 
    <quartz:inbound-endpoint jobName="job1" cronExpression="0/5 * * * * ?" connector-ref="quartzConnector"> 
    <quartz:event-generator-job> 
     <quartz:payload>foo</quartz:payload> 
    </quartz:event-generator-job> 
    </quartz:inbound-endpoint> 

    <logger message="#[process:test:#[payload]]" level="INFO"/> 
</flow> 

<sub-flow name="test" doc:name="test"> 
    <component class="com.myComp.ComponentTest" doc:name="Java"/> 
</sub-flow> 

這是我的Java組件：

package com.myComp; 

public class ComponentTest 
{ 
    public String test(String s) 
    { 
    return s + "bar"; 
    } 
} 

時表達#[process:test:#[payload]]評估問題來了。它會拋出以下異常：

java.lang.NullPointerException 
    at org.mule.component.AbstractComponent.invokeInternal(AbstractComponent.java:112) 
    at org.mule.component.AbstractComponent.process(AbstractComponent.java:156) 
    at org.mule.processor.chain.DefaultMessageProcessorChain.doProcess(DefaultMessageProcessorChain.java:99) 
    at org.mule.processor.chain.AbstractMessageProcessorChain.process(AbstractMessageProcessorChain.java:66) 
    at org.mule.processor.chain.InterceptingChainLifecycleWrapper.doProcess(InterceptingChainLifecycleWrapper.java:56) 
    at org.mule.processor.chain.AbstractMessageProcessorChain.process(AbstractMessageProcessorChain.java:66) 
    at org.mule.processor.chain.InterceptingChainLifecycleWrapper.process(InterceptingChainLifecycleWrapper.java:87) 
    at org.mule.api.processor.MessageProcessors$LifecyleAwareMessageProcessorWrapper.process(MessageProcessors.java:114) 
    at org.mule.expression.MessageProcessorExpressionEvaluator.evaluate(MessageProcessorExpressionEvaluator.java:87) 
    at org.mule.expression.DefaultExpressionManager.evaluate(DefaultExpressionManager.java:273) 
    at org.mule.expression.DefaultExpressionManager.evaluate(DefaultExpressionManager.java:209) 
    at org.mule.expression.DefaultExpressionManager$1.match(DefaultExpressionManager.java:399) 
    at org.mule.util.TemplateParser.parse(TemplateParser.java:156) 
    at org.mule.util.TemplateParser.parse(TemplateParser.java:133) 
    at org.mule.expression.DefaultExpressionManager.parse(DefaultExpressionManager.java:395) 
    at org.mule.expression.DefaultExpressionManager.parse(DefaultExpressionManager.java:379) 
    at org.mule.api.processor.LoggerMessageProcessor.log(LoggerMessageProcessor.java:89) 
    at org.mule.api.processor.LoggerMessageProcessor.process(LoggerMessageProcessor.java:71) 
    at org.mule.processor.chain.DefaultMessageProcessorChain.doProcess(DefaultMessageProcessorChain.java:99) 
    at org.mule.processor.chain.AbstractMessageProcessorChain.process(AbstractMessageProcessorChain.java:66) 
    at org.mule.processor.AbstractInterceptingMessageProcessorBase.processNext(AbstractInterceptingMessageProcessorBase.java:105) 
    at org.mule.interceptor.AbstractEnvelopeInterceptor.process(AbstractEnvelopeInterceptor.java:55) 
    at org.mule.processor.AsyncInterceptingMessageProcessor.processNextTimed(AsyncInterceptingMessageProcessor.java:111) 
    at org.mule.processor.AsyncInterceptingMessageProcessor$AsyncMessageProcessorWorker.doRun(AsyncInterceptingMessageProcessor.java:158) 
    at org.mule.work.AbstractMuleEventWork.run(AbstractMuleEventWork.java:43) 
    at org.mule.work.WorkerContext.run(WorkerContext.java:310) 
    at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(Unknown Source) 
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) 
    at java.lang.Thread.run(Unknown Source) 

其他任何腳本組件都會發生同樣的情況。 我猜它與我的組件生命週期有關，但是我找不到一種方法來使它工作。 如果我用任何其他Mule處理器（例如記錄器，stringAppend）替換我的組件，它工作正常。

任何幫助將不勝感激！

Answer 1

當你說這是一個初始化問題時，你是對的：出於任何原因，子流程中的組件並不像它們在流程中那樣初始化，即。這個作品：

<flow name="test" doc:name="test"> 
    <component class="com.myComp.ComponentTest" doc:name="Java"/> 
</flow> 

我相信這是一個錯誤因此I reported it。請注意這個問題。

要使用異步事件工作，就像Quartz入站端點生成的那樣，您需要將processingStrategy="synchronous"添加到被調用流中以便同步調用，否則默認情況下將異步調用（即使process:test:#[payload]需要同步響應）。這是在騾子3

已知怪癖所以最終的解決方案是：

<flow name="test" processingStrategy="synchronous" doc:name="test"> 
    <component class="com.myComp.ComponentTest" doc:name="Java"/> 
</flow>