From b2edab2e87aea67e3934465bd95dfa16c119aef3 Mon Sep 17 00:00:00 2001
From: Mark Fisher <markfisher@vmware.com>
Date: Fri, 3 Jul 2009 14:30:40 +0000
Subject: [PATCH] added volatile keyword for correlationStrategy

---
 .../integration/aggregator/AbstractMessageBarrierHandler.java | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/org.springframework.integration/src/main/java/org/springframework/integration/aggregator/AbstractMessageBarrierHandler.java b/org.springframework.integration/src/main/java/org/springframework/integration/aggregator/AbstractMessageBarrierHandler.java
index 3b3a7f5410..5cbb78a265 100644
--- a/org.springframework.integration/src/main/java/org/springframework/integration/aggregator/AbstractMessageBarrierHandler.java
+++ b/org.springframework.integration/src/main/java/org/springframework/integration/aggregator/AbstractMessageBarrierHandler.java
@@ -66,7 +66,7 @@ import org.springframework.util.Assert;
  * <p>
  * Subclasses must decide what kind of a Collection they want to use. The semantics
  * of adding a Message to the MessageBarrier will be decided by the Collection type.
- *
+ * <p>
  * Note: this class is not part of the Spring Integration API, but
  * an internal class, used for implementing components that need to keep
  * a list of messages until they are ready to be released or processed
@@ -117,7 +117,7 @@ public abstract class AbstractMessageBarrierHandler<T extends Collection<? exten
 
 	private final Object lifecycleMonitor = new Object();
 
-    private CorrelationStrategy correlationStrategy = new HeaderAttributeCorrelationStrategy(MessageHeaders.CORRELATION_ID);
+    private volatile CorrelationStrategy correlationStrategy = new HeaderAttributeCorrelationStrategy(MessageHeaders.CORRELATION_ID);
 
 
     public AbstractMessageBarrierHandler() {