0

我使用以下流程来聚合来自 JMS 主题的消息。

<jms:inbound-endpoint  connector-ref="SonicEng" doc:name="JMS" topic="TESTTOPIC"/>   
<set-property propertyName="MULE_CORRELATION_GROUP_SIZE" value="10" doc:name="Property" />      
<set-property propertyName="MULE_CORRELATION_ID" value="#[(String)app.registry.uniqueId]"   doc:name="Property" />
<collection-aggregator failOnTimeout="false" doc:name="Collection Aggregator" timeout="100"/>   
<expression-component doc:name="Expression">
    app.registry.uniqueId = 1 * app.registry.uniqueId + 1
</expression-component>
<logger message="Message: #[message.payload]" level="INFO" doc:name="Logger"/>

当消息负载非常高时,抛出以下异常:

event.correlator" java.lang.IndexOutOfBoundsException: Index: 0, Size: 0
at java.util.ArrayList.rangeCheck(ArrayList.java:604)
at java.util.ArrayList.get(ArrayList.java:382)
at org.mule.routing.EventGroup.getMessageCollectionEvent(EventGroup.java:436)
at org.mule.routing.correlation.EventCorrelator$ExpiringGroupMonitoringThread.doRun(EventCorrelator.java:569)
at org.mule.routing.EventProcessingThread.run(EventProcessingThread.java:85)

我使用 Mule EE 版本 3.4.0。是否有人对此有解决方案,或者可以忽略它,因为它与 ExpiringGroupMonitoringThread 相关?感谢您的回复!

我在 Mule EE 3.4.1 中遇到以下异常。我觉得这与同一个问题有关。

Exception in thread "[appname].monorail.event.correlator"   java.lang.UnsupportedOperationException
at org.mule.VoidMuleEvent.getFlowConstruct(VoidMuleEvent.java:138)
at org.mule.routing.correlation.EventCorrelator$ExpiringGroupMonitoringThread.doRun(EventCorrelator.java:569)
at org.mule.routing.EventProcessingThread.run(EventProcessingThread.java:85)

当使用大量数据时,我们会在关联聚合器之后丢失消息。这些异常是否与丢失的消息有关?

4

0 回答 0