Spring/spring-integration
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Added consumer policy configuration based on @Polled period.

Browse Source
This commit is contained in:
Mark Fisher
2007-12-14 19:21:23 +00:00
parent cfe5c53b99
commit b172886f79
1 changed files with 7 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
spring-eai-core/src/main/java/org/springframework/integration/endpoint/annotation/EndpointAnnotationPostProcessor.java
View File

@@ -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;
}
}