From 58836bcc50101cd01892e0d5939ebb47bc762793 Mon Sep 17 00:00:00 2001
From: Mark Fisher <markfisher@vmware.com>
Date: Fri, 21 Dec 2007 22:19:12 +0000
Subject: [PATCH] Using an AtomicInteger for incrementAndGet.

---
 .../integration/samples/oddeven/Counter.java                | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/spring-integration-samples/src/main/java/org/springframework/integration/samples/oddeven/Counter.java b/spring-integration-samples/src/main/java/org/springframework/integration/samples/oddeven/Counter.java
index c710a8b7ed..d523826998 100644
--- a/spring-integration-samples/src/main/java/org/springframework/integration/samples/oddeven/Counter.java
+++ b/spring-integration-samples/src/main/java/org/springframework/integration/samples/oddeven/Counter.java
@@ -16,6 +16,8 @@
 
 package org.springframework.integration.samples.oddeven;
 
+import java.util.concurrent.atomic.AtomicInteger;
+
 import org.springframework.integration.endpoint.annotation.MessageEndpoint;
 import org.springframework.integration.endpoint.annotation.Polled;
 import org.springframework.integration.handler.annotation.Router;
@@ -26,11 +28,11 @@ import org.springframework.integration.handler.annotation.Router;
 @MessageEndpoint
 public class Counter {
 
-	private volatile int count = 1;
+	private AtomicInteger count = new AtomicInteger();
 
 	@Polled(period=3000)
 	public int getNumber() {
-		return count++;
+		return count.incrementAndGet();
 	}
 
 	@Router