0

Oracleテーブルに100行ある場合、本文に100行を含む1つの電子メールを受信したいのですが、代わりに各行に1つずつ、100の電子メールを受信します。 false、結果セット全体に対して単一のトランザクションがあります」）が、trueに設定してもfalseに設定しても違いはありません。

<?xml version="1.0" encoding="UTF-8"?>

<mule xmlns:smtp="http://www.mulesoft.org/schema/mule/smtp" xmlns:jbossts="http://www.mulesoft.org/schema/mule/jbossts" xmlns:jdbc="http://www.mulesoft.org/schema/mule/jdbc" xmlns="http://www.mulesoft.org/schema/mule/core" xmlns:doc="http://www.mulesoft.org/schema/mule/documentation" xmlns:spring="http://www.springframework.org/schema/beans" version="CE-3.3.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="
http://www.mulesoft.org/schema/mule/smtp http://www.mulesoft.org/schema/mule/smtp/current/mule-smtp.xsd 
http://www.mulesoft.org/schema/mule/jdbc http://www.mulesoft.org/schema/mule/jdbc/current/mule-jdbc.xsd 
http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-current.xsd 
http://www.mulesoft.org/schema/mule/core http://www.mulesoft.org/schema/mule/core/current/mule.xsd 
http://www.mulesoft.org/schema/mule/jbossts http://www.mulesoft.org/schema/mule/jbossts/current/mule-jbossts.xsd ">
    <jdbc:oracle-data-source name="Oracle_Data_Source" user="test" password="test" url="jdbc:oracle:thin:@//ora:1530/TEST.EXAMPLE.COM" transactionIsolation="UNSPECIFIED" doc:name="Oracle Data Source"/>
    <jdbc:connector name="Database" dataSource-ref="Oracle_Data_Source" validateConnections="true" transactionPerMessage="false" queryTimeout="-1" pollingFrequency="5000" doc:name="Database"/>
    <flow name="Ross_invoice_Workflow2Flow1" doc:name="Ross_invoice_Workflow2Flow1">
        <jdbc:inbound-endpoint queryKey="GetUnprocessedInvoices" queryTimeout="-1" pollingFrequency="1000" connector-ref="Database" doc:name="Database">
            <jdbc:query key="GetUnprocessedInvoices" value="SELECT        INVOICE_NUMBER FROM            FIN.LHF_INVOICE_WORKFLOW&#13;&#10;WHERE        (STATUS_FLAG = 'N')"/>
        </jdbc:inbound-endpoint>
        <echo-component doc:name="Echo"/>
        <smtp:outbound-endpoint host="mail.example.com" to="test@example.com" from="mule@example.com" subject="invoice test" responseTimeout="10000" doc:name="SMTP"/>
    </flow>
</mule>
4

2 に答える 2

1

Muleに、現在のように行ごとに1つのメッセージを作成させてから、アグリゲーターを使用してメッセージを100でグループ化します。また、おそらく100に達しない最後のグループのアグリゲーターのタイムアウトを構成する必要があります（レコードは常に100の倍数です）。

于 2012-12-05T00:13:59.747 に答える
0

エンドポイントでtransactionPerMessageプロパティを「true」に設定し、次のようなトランザクションを追加する場合も、コネクタでtransactionPerMessageを「false」に設定すると機能するはずです。

<jdbc:inbound-endpoint queryKey="GetUnprocessedInvoices" queryTimeout="-1"   pollingFrequency="1000" connector-ref="Database" doc:name="Database">
    <jdbc:query key="GetUnprocessedInvoices" value="SELECT        INVOICE_NUMBER FROM            FIN.LHF_INVOICE_WORKFLOW&#13;&#10;WHERE        (STATUS_FLAG = 'N')"/>
    <jdbc:transaction action="ALWAYS_BEGIN"/>
    <property key="receiveMessageInTransaction" value="true"/>
</jdbc:inbound-endpoint>
于 2013-04-09T19:37:38.680 に答える