[Carbon-dev] [jira] Created: (CARBON-4953) ESB - ConcurrentModificationException thrown when executing a sequence with an Aggregate mediator with 50 iterations

Evanthika Amarasiri (JIRA) jira at wso2.org
Mon Jul 20 21:39:00 PDT 2009


ESB - ConcurrentModificationException thrown when executing a sequence with an Aggregate mediator with 50 iterations
--------------------------------------------------------------------------------------------------------------------

                 Key: CARBON-4953
                 URL: https://wso2.org/jira/browse/CARBON-4953
             Project: WSO2 Carbon
          Issue Type: Bug
          Components: Mediators
         Environment: Windows XP, JDK1.5.0_17
            Reporter: Evanthika Amarasiri
            Assignee: Ruwan Linton
            Priority: High


Steps to reproduce

1. Create the following sequence
<syn:sequence xmlns:syn="http://ws.apache.org/ns/synapse" name="aggregate">
   <syn:in>
      <syn:iterate xmlns:ns="http://org.apache.synapse/xsd" xmlns:ns2="http://org.apache.synapse/xsd" xmlns:m0="http://services.samples" preservePayload="true" attachPath="//m0:getQuote" expression="//m0:getQuote/m0:request">
         <syn:target>
            <syn:sequence>
               <syn:send>
                  <syn:endpoint>
                     <syn:address uri="http://localhost:9000/services/SimpleStockQuoteService" />
                  </syn:endpoint>
               </syn:send>
            </syn:sequence>
         </syn:target>
      </syn:iterate>
   </syn:in>
   <syn:out>
      <syn:aggregate>
         <syn:completeCondition timeout="5">
            <syn:messageCount min="-1" max="-1" />
         </syn:completeCondition>
         <syn:onComplete xmlns:ns="http://org.apache.synapse/xsd" xmlns:ns2="http://org.apache.synapse/xsd" xmlns:m0="http://services.samples" expression="//m0:getQuoteResponse">
            <syn:send />
         </syn:onComplete>
      </syn:aggregate>
   </syn:out>
</syn:sequence>
2. Sent 50 sequences
3. The following exception was thrown on the console

[2009-07-21 09:59:46,000] DEBUG - OutMediator Current message is outgoing - executing child mediators
[2009-07-21 09:59:46,031] ERROR - NativeWorkerPool Uncaught exception
java.util.ConcurrentModificationException
        at java.util.AbstractList$Itr.checkForComodification(AbstractList.java:449)
        at java.util.AbstractList$Itr.next(AbstractList.java:420)
        at org.apache.synapse.mediators.eip.aggregator.AggregateMediator.getAggregatedMessage(AggregateMediator.java:348)
        at org.apache.synapse.mediators.eip.aggregator.AggregateMediator.completeAggregate(AggregateMediator.java:311)
        at org.apache.synapse.mediators.eip.aggregator.AggregateMediator.mediate(AggregateMediator.java:256)
        at org.apache.synapse.mediators.AbstractListMediator.mediate(AbstractListMediator.java:60)
        at org.apache.synapse.mediators.filters.OutMediator.mediate(OutMediator.java:55)
        at org.apache.synapse.mediators.AbstractListMediator.mediate(AbstractListMediator.java:60)
        at org.apache.synapse.mediators.base.SequenceMediator.mediate(SequenceMediator.java:115)
        at org.apache.synapse.mediators.base.SequenceMediator.mediate(SequenceMediator.java:162)
        at org.apache.synapse.mediators.AbstractListMediator.mediate(AbstractListMediator.java:60)
        at org.apache.synapse.mediators.base.SequenceMediator.mediate(SequenceMediator.java:115)
        at org.apache.synapse.core.axis2.Axis2SynapseEnvironment.injectMessage(Axis2SynapseEnvironment.java:131)
        at org.apache.synapse.core.axis2.SynapseCallbackReceiver.handleMessage(SynapseCallbackReceiver.java:339)
        at org.apache.synapse.core.axis2.SynapseCallbackReceiver.receive(SynapseCallbackReceiver.java:135)
        at org.apache.axis2.engine.AxisEngine.receive(AxisEngine.java:178)
        at org.apache.synapse.transport.nhttp.ClientWorker.run(ClientWorker.java:230)
        at org.apache.axis2.transport.base.threads.NativeWorkerPool$1.run(NativeWorkerPool.java:58)
        at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:650)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:675)
        at java.lang.Thread.run(Thread.java:595)
[2009-07-21 09:59:46,046] DEBUG - AddressEndpoint Sending message through endpoint : null resolving to address = http://localhost:9000/services/SimpleStockQuoteService
[2009-07-21 09:59:46,046] DEBUG - IterateMediator Submitting 37 of 36 messages for processing in parallel

-- 
This message is automatically generated by JIRA.
-
If you think it was sent incorrectly contact one of the administrators: https://wso2.org/jira/secure/Administrators.jspa
-
For more information on JIRA, see: http://www.atlassian.com/software/jira

        



More information about the Carbon-dev mailing list