Quartz 生成器和异常处理

Question

我有一个工作流程如下：

<flow name="ChatListener">
    <quartz:inbound-endpoint jobName="eventTimer"
        repeatInterval="${chatListener.pollingInterval}">
        <quartz:event-generator-job />
    </quartz:inbound-endpoint>
    <filter ref="ActiveTrainingFilter" />

    <component>
        <singleton-object class="com.ChatListener.ChatListener" />
    </component>



    <not-filter>
        <payload-type-filter expectedType="org.mule.transport.NullPayload" />
    </not-filter>

    <collection-splitter />

    <vm:outbound-endpoint path="ChatMsgs"
        exchange-pattern="one-way" />
    <default-exception-strategy>
        <vm:outbound-endpoint path="ErrorMsgs"/>
    </default-exception-strategy>
</flow>

现在，实际发生的是生成器调用单例组件，该组件执行一些数据库检索并返回一个 java bean 类的集合，我稍后将其拆分（空过滤器是在我想要的情况下）以停止流动）。

我的问题是 - 假设我连接到数据库时出错，并且组件的初始化失败。什么会阻止生成器一次又一次地尝试调用组件？ （并且每次都会产生错误）。

在我看来，好像我处理的事情不太正确，那么实现它来处理异常有什么好处呢？

有什么想法吗？提前致谢！

Answer 1

我会尝试以下操作：

• 以全局方式声明石英端点，
• 在流程中使用它。
• 创建自定义异常策略并在流程中使用它。
• 在此自定义异常策略中注入全局quartz端点。
• 在此策略中，如果捕获的异常是您认为不可恢复故障的特征，请调用端点.stop()。

清除错误条件后，您需要通过 JMX 重新启动端点。