0

ミュール スタンドアロン 3.4 を使用しています。Salesforce コネクタを使用してクエリ操作を実行し、ペイロードをスプリング コンポーネントに渡すフローを作成しようとしています。その結果、コンポーネントは呼び出されません。

    <flow name="sfcdContact" doc:name="sfcdContact">
    <quartz:inbound-endpoint repeatInterval="2000" 
                             startDelay="3000" 
                             jobName="sfcdContact">
        <quartz:event-generator-job/>
    </quartz:inbound-endpoint> 
    <sfdc:query config-ref="Salesforce" 
                query="${salesforce.query.contact}" 
                doc:name="sfcdContactQuery"/>
    <component>
        <spring-object bean="salesForceConsumer"/>      
    </component>
    <catch-exception-strategy doc:name="Catch Exception Strategy">
        <flow-ref name="ErrorHandling"/>
    </catch-exception-strategy> 
</flow>

フローから sfdc 部分を削除すると、Spring コンポーネントが正常に呼び出されます。フローからコンポーネント部分を削除して、次のものに置き換えると:

         <logger message="\#\#\# query operation payload \#[payload]" level="INFO" doc:name="Logger"/>

結果は正常にログに入力されます。そのため、ピースは個別に正しく機能しているようです。

ログをデバッグに設定しましたが、エラーは報告されません。

Javaコードは次のとおりです。

 public class SalesForceConsumer {

    public Object consume(@Payload Object payload) throws Exception {
        System.out.println("SalesForceConsumer::consume called");
        return payload;
    }


 }

また、署名を次のように変更しようとしました。

 public Object consume(@Payload HashMap<String,Object> payload)

これは、ドキュメントがコネクタから返されることを示しています。

Salesforce コネクタを Bean と組み合わせることができない理由はありますか? または、正しく構成されていませんか? ありがとうございました。

4

1 に答える 1

0

あなたのコードを Mule EE 3.4 で実行したところ、問題なく動作しました。

コンソール出力:

INFO 2015-03-26 18:37:51,903 org.mule.api.processor.LoggerMessageProcessor: \#\#\# query operation payload \[{FirstName=Test, Id=null, type=Contact}]
SalesForceConsumer::consume called

流れ：

<spring:beans>
    <spring:bean id="salesForceConsumer" name="salesForceConsumer" class="com.acme.util.SalesForceConsumer"/>
</spring:beans>
<sfdc:config name="Salesforce" username="XXXX" password="XXXX" securityToken="XXXX" url="https://login.salesforce.com/services/Soap/u/28.0" doc:name="Salesforce">
    <sfdc:connection-pooling-profile initialisationPolicy="INITIALISE_ONE"  exhaustedAction="WHEN_EXHAUSTED_GROW"/>
</sfdc:config>
<flow name="sfcdContact" doc:name="sfcdContact">
    <quartz:inbound-endpoint repeatInterval="2000" startDelay="3000" jobName="sfcdContact">
       <quartz:event-generator-job/>
    </quartz:inbound-endpoint> 
    <sfdc:query config-ref="Salesforce" query="select FirstName from Contact" doc:name="sfcdContactQuery"/>
    <logger message="\#\#\# query operation payload \#[payload]" level="INFO" doc:name="Logger"/>
    <component>
       <spring-object bean="salesForceConsumer"/>      
    </component>
</flow>
于 2015-03-31T03:13:29.223 に答える