diff --git a/org.springframework.integration/src/main/java/org/springframework/integration/config/xml/PointToPointChannelParser.java b/org.springframework.integration/src/main/java/org/springframework/integration/config/xml/PointToPointChannelParser.java index c79f8e3b85..29164598d2 100644 --- a/org.springframework.integration/src/main/java/org/springframework/integration/config/xml/PointToPointChannelParser.java +++ b/org.springframework.integration/src/main/java/org/springframework/integration/config/xml/PointToPointChannelParser.java @@ -65,9 +65,7 @@ public class PointToPointChannelParser extends AbstractChannelParser { private void parseQueueCapacity(BeanDefinitionBuilder builder, Element queueElement) { String capacity = queueElement.getAttribute(CAPACITY_ATTRIBUTE); if (StringUtils.hasText(capacity)) { - if (!capacity.equals("UNBOUNDED")) { - builder.addConstructorArgValue(Integer.valueOf(capacity)); - } + builder.addConstructorArgValue(Integer.valueOf(capacity)); } }