From b172886f798f24db3fe7e7833e0142802dc561a5 Mon Sep 17 00:00:00 2001
From: Mark Fisher <markfisher@vmware.com>
Date: Fri, 14 Dec 2007 19:21:23 +0000
Subject: [PATCH] Added consumer policy configuration based on @Polled period.

---
 .../annotation/EndpointAnnotationPostProcessor.java        | 7 +++++++
 1 file changed, 7 insertions(+)

diff --git a/spring-eai-core/src/main/java/org/springframework/integration/endpoint/annotation/EndpointAnnotationPostProcessor.java b/spring-eai-core/src/main/java/org/springframework/integration/endpoint/annotation/EndpointAnnotationPostProcessor.java
index c2902d022d..71d7829a6c 100644
--- a/spring-eai-core/src/main/java/org/springframework/integration/endpoint/annotation/EndpointAnnotationPostProcessor.java
+++ b/spring-eai-core/src/main/java/org/springframework/integration/endpoint/annotation/EndpointAnnotationPostProcessor.java
@@ -112,6 +112,13 @@ public class EndpointAnnotationPostProcessor implements BeanPostProcessor, Initi
 					String channelName = beanName + "-inputChannel";
 					messageBus.registerChannel(channelName, adapter);
 					endpoint.setInputChannelName(channelName);
+					int period = ((Polled) annotation).period();
+					endpoint.getConsumerPolicy().setPeriod(period);
+					if (period > 0) {
+						endpoint.getConsumerPolicy().setConcurrency(1);
+						endpoint.getConsumerPolicy().setMaxConcurrency(1);
+						endpoint.getConsumerPolicy().setMaxMessagesPerTask(1);
+					}
 					return;
 				}
 			}