Actually accept String expressions for "prefetch" and "receive-timeout" in jms namespace
Issue: SPR-10986
This commit is contained in:
parent
2d2226baf6
commit
ccafccbec8
|
|
@ -151,14 +151,14 @@ class JmsListenerContainerParser extends AbstractListenerContainerParser {
|
||||||
String prefetch = containerEle.getAttribute(PREFETCH_ATTRIBUTE);
|
String prefetch = containerEle.getAttribute(PREFETCH_ATTRIBUTE);
|
||||||
if (StringUtils.hasText(prefetch)) {
|
if (StringUtils.hasText(prefetch)) {
|
||||||
if (containerType.startsWith("default")) {
|
if (containerType.startsWith("default")) {
|
||||||
containerDef.getPropertyValues().add("maxMessagesPerTask", new Integer(prefetch));
|
containerDef.getPropertyValues().add("maxMessagesPerTask", prefetch);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
String receiveTimeout = containerEle.getAttribute(RECEIVE_TIMEOUT_ATTRIBUTE);
|
String receiveTimeout = containerEle.getAttribute(RECEIVE_TIMEOUT_ATTRIBUTE);
|
||||||
if (StringUtils.hasText(receiveTimeout)) {
|
if (StringUtils.hasText(receiveTimeout)) {
|
||||||
if (containerType.startsWith("default")) {
|
if (containerType.startsWith("default")) {
|
||||||
containerDef.getPropertyValues().add("receiveTimeout", new Integer(receiveTimeout));
|
containerDef.getPropertyValues().add("receiveTimeout", receiveTimeout);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue