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

Add reconnection logic to SimpleMessageListenerContainer.

Browse Source 
Test for SimpleMessageListenerContainer's ExceptionListener being invoked (SPRNET-542)
This commit is contained in:
markpollack
2008-08-11 21:25:30 +00:00
parent a79d4769dc
commit d6a5fd2524
3 changed files with 19 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
doc/reference/src/messaging.xml
View File

@@ -1266,6 +1266,22 @@ namespace MyApp
important; consider raising it for general
queues.</para></entry>
</row>
<row>
<entry>recovery-interval</entry>
<entry><para>The time interval between connection recovery attempts. The default is 5 seconds.
Specify as a TimeSpan value using Spring's TimeSpanConverter (e.g. 10s, 10m, 3h, etc)
</para></entry>
</row>
<row>
<entry>max-recovery-time</entry>
<entry><para>The maximum time try reconnection attempts. The default is 10 minutes. Specify as a
TimeSpan value using Spring's TimeSpanConverter (e.g. 10s, 10m, 3h, etc)
</para></entry>
</row>
</tbody>
</tgroup>
</table>

6
src/Spring/Spring.Messaging.Nms/Messaging/Nms/Config/MessageListenerContainerObjectDefinitionParser.cs
View File

@@ -85,7 +85,7 @@ namespace Spring.Messaging.Nms.Config
private readonly string RECOVERY_INTERVAL_ATTRIBUTE = "recovery-interval";
private readonly string MAX_RECOVERY_INTERVAL_ATTRIBUTE = "max-recovery-interval";
private readonly string MAX_RECOVERY_TIME_ATTRIBUTE = "max-recovery-time";
private readonly string CONNECTION_FACTORY_ATTRIBUTE = "connection-factory";
@@ -392,7 +392,7 @@ namespace Spring.Messaging.Nms.Config
}
private TimeSpan ParseMaxRecoveryTime(XmlElement ele, ParserContext parserContext)
{
string recoverTime = ele.GetAttribute(MAX_RECOVERY_INTERVAL_ATTRIBUTE);
string recoverTime = ele.GetAttribute(MAX_RECOVERY_TIME_ATTRIBUTE);
if (!StringUtils.HasText(recoverTime))
{
return SimpleMessageListenerContainer.DEFAULT_MAX_RECOVERY_TIME;
@@ -404,7 +404,7 @@ namespace Spring.Messaging.Nms.Config
}
catch (Exception ex)
{
parserContext.ReaderContext.ReportException(ele, MAX_RECOVERY_INTERVAL_ATTRIBUTE,
parserContext.ReaderContext.ReportException(ele, MAX_RECOVERY_TIME_ATTRIBUTE,
"Invalid max-recovery-time value [" + recoverTime + "]", ex);
return SimpleMessageListenerContainer.DEFAULT_MAX_RECOVERY_TIME;
}

1
src/Spring/Spring.Messaging.Nms/Messaging/Nms/Config/spring-nms-1.2.xsd
View File

@@ -123,7 +123,6 @@
</xsd:documentation>
</xsd:annotation>
</xsd:attribute>
</xsd:attribute>
<xsd:attribute name="max-recovery-time" type="xsd:string">
<xsd:annotation>
<xsd:documentation>