mysql - 在 Mule 中限制 Mule 消息

Question

我在 Mule 中有一个轮询过程，每 30 秒查询一次 MySQL 数据库并向收件人发送一封电子邮件。无论轮询周期是 30 秒还是 15 秒，如何限制只发送 1 封电子邮件？如果可以的话，我也愿意在 mysql 数据库中设置一个计数器。

谢谢。

Answer 1

编写一个条件，仅在 emailSentFlag == false 时才发送电子邮件。

使用选择路由器创建条件，并使用对象存储来保存 emailSentFlag 值。

<flow...>
        ....
        <objectstore:retrieve config-ref="ObjectStore__Configuration" key="emailSentFlag" defaultValue-ref="#[false]" targetProperty="flowVars.emailSentFlag" doc:name="retrieve emailSentFlag"/>
        <choice doc:name="IsEmailSent?">
            <when expression="#[flowVars.emailSentFlag == true]">
                <logger level="INFO" doc:name="Log Email Already Sent"/>
            </when>
            <otherwise>
                <smtp:outbound-endpoint host="" user="" password="" to="" from="" subject="test" cc="" bcc="" replyTo="" responseTimeout="10000" ref="Gmail" doc:name="SMTP" connector-ref="Gmail"/>
                <objectstore:store config-ref="ObjectStore__Configuration" key="emailSentFlag" value-ref="#[true]" doc:name="store emailSentFlag"/>
            </otherwise>
        </choice>
    </flow>

还可以探索对象存储的 TTL 和持久性功能，它可能对您有用。

干杯