INT-813 added support for configurable 'receive-timeout' on JMS channels

This commit is contained in:
Mark Fisher
2010-09-23 18:23:39 -04:00
parent c05e5db50a
commit c521fc9531
3 changed files with 10 additions and 0 deletions

View File

@@ -264,6 +264,7 @@ public class JmsChannelFactoryBean extends AbstractFactoryBean<AbstractJmsChanne
public void setReceiveTimeout(long receiveTimeout) {
this.receiveTimeout = receiveTimeout;
this.jmsTemplate.setReceiveTimeout(receiveTimeout);
}
public void setRecoveryInterval(long recoveryInterval) {

View File

@@ -78,6 +78,7 @@ public class JmsChannelParser extends AbstractChannelParser {
containerType = "default";
}
}
IntegrationNamespaceUtils.setValueIfAttributeDefined(builder, element, "receive-timeout");
IntegrationNamespaceUtils.setReferenceIfAttributeDefined(builder, element, "task-executor");
IntegrationNamespaceUtils.setReferenceIfAttributeDefined(builder, element, "transaction-manager");
IntegrationNamespaceUtils.setReferenceIfAttributeDefined(builder, element, "message-converter");

View File

@@ -196,6 +196,14 @@
</xsd:appinfo>
</xsd:annotation>
</xsd:attribute>
<xsd:attribute name="receive-timeout" type="xsd:string">
<xsd:annotation>
<xsd:documentation>
Timeout for the container's consumers if messsage-driven is TRUE, or
timeout for receive calls on the template if message-driven is FALSE.
</xsd:documentation>
</xsd:annotation>
</xsd:attribute>
<xsd:attribute name="task-executor" type="xsd:string">
<xsd:annotation>
<xsd:documentation><![CDATA[