From b1d647298ac933b6b006874d27d9e710e2cdf6cf Mon Sep 17 00:00:00 2001 From: Mark Fisher Date: Mon, 13 Oct 2008 23:28:55 +0000 Subject: [PATCH] Added 'max-messages-per-poll' value (INT-412). --- .../integration/config/xml/AbstractConsumerEndpointParser.java | 1 + 1 file changed, 1 insertion(+) diff --git a/org.springframework.integration/src/main/java/org/springframework/integration/config/xml/AbstractConsumerEndpointParser.java b/org.springframework.integration/src/main/java/org/springframework/integration/config/xml/AbstractConsumerEndpointParser.java index 90cfdb2c04..3a8f2e5411 100644 --- a/org.springframework.integration/src/main/java/org/springframework/integration/config/xml/AbstractConsumerEndpointParser.java +++ b/org.springframework.integration/src/main/java/org/springframework/integration/config/xml/AbstractConsumerEndpointParser.java @@ -108,6 +108,7 @@ public abstract class AbstractConsumerEndpointParser extends AbstractSingleBeanD Element pollerElement = DomUtils.getChildElementByTagName(element, POLLER_ELEMENT); if (pollerElement != null) { IntegrationNamespaceUtils.configureTrigger(pollerElement, builder); + IntegrationNamespaceUtils.setValueIfAttributeDefined(builder, pollerElement, "max-messages-per-poll"); Element txElement = DomUtils.getChildElementByTagName(pollerElement, "transactional"); if (txElement != null) { IntegrationNamespaceUtils.configureTransactionAttributes(txElement, builder);