Author: supun
Date: Fri May 20 06:40:42 2011
New Revision: 1125255
URL: http://svn.apache.org/viewvc?rev=1125255&view=rev
Log:
fixing a concurrent modification exception
Modified:
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/eip/aggregator/Aggregate.java
Modified:
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/eip/aggregator/Aggregate.java
URL:
http://svn.apache.org/viewvc/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/eip/aggregator/Aggregate.java?rev=1125255&r1=1125254&r2=1125255&view=diff
==============================================================================
---
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/eip/aggregator/Aggregate.java
(original)
+++
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/eip/aggregator/Aggregate.java
Fri May 20 06:40:42 2011
@@ -199,8 +199,8 @@ public class Aggregate extends TimerTask
this.correlation = correlation;
}
- public List<MessageContext> getMessages() {
- return messages;
+ public synchronized List<MessageContext> getMessages() {
+ return new ArrayList<MessageContext>(messages);
}
public void setMessages(List<MessageContext> messages) {
