SPRNET-1130 - Wrong MessageQueueException handling in DistributedTxMessageListenerContainer and TransactionalMessageListenerContainer
This commit is contained in:
@@ -134,7 +134,6 @@ namespace Spring.Messaging.Listener
|
||||
|
||||
/// <summary>
|
||||
/// Wait for all listener threads to exit and closes the DefaultMessageQueue.
|
||||
/// <see cref="AbstractMessageListenerContainer.CloseQueueHandle"/>
|
||||
/// </summary>
|
||||
protected override void DoShutdown()
|
||||
{
|
||||
|
||||
@@ -116,7 +116,7 @@ namespace Spring.Messaging.Listener
|
||||
}
|
||||
catch (MessageQueueException ex)
|
||||
{
|
||||
if (ex.MessageQueueErrorCode != MessageQueueErrorCode.IOTimeout)
|
||||
if (ex.MessageQueueErrorCode == MessageQueueErrorCode.IOTimeout)
|
||||
{
|
||||
//expected to occur occasionally
|
||||
|
||||
|
||||
@@ -309,7 +309,7 @@ namespace Spring.Messaging.Listener
|
||||
}
|
||||
catch (MessageQueueException ex)
|
||||
{
|
||||
if (ex.MessageQueueErrorCode != MessageQueueErrorCode.IOTimeout)
|
||||
if (ex.MessageQueueErrorCode == MessageQueueErrorCode.IOTimeout)
|
||||
{
|
||||
//expected to occur occasionally
|
||||
if (LOG.IsTraceEnabled)
|
||||
|
||||
Reference in New Issue
Block a user