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

SPRNET-1253 - NmsTemplate: wrong timeout units in receive method (ticks instead of milliseconds)

Browse Source
This commit is contained in:
markpollack
2009-10-30 20:59:45 +00:00
parent f6ae679a2f
commit ce9ee2d4d2
1 changed files with 11 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
src/Spring/Spring.Messaging.Nms/Messaging/Nms/Core/NmsTemplate.cs
View File

@@ -55,13 +55,19 @@ namespace Spring.Messaging.Nms.Core
#endregion
#region Fields
/// <summary>
/// Timeout value indicating that a receive operation should
/// check if a message is immediately available without blocking.
/// </summary>
public static readonly long DEFAULT_RECEIVE_TIMEOUT = -1;
public static readonly long RECEIVE_TIMEOUT_NO_WAIT = -1;
/// <summary>
/// Timeout value indicating a blocking receive without timeout.
/// </summary>
public static readonly long RECEIVE_TIMEOUT_INDEFINITE_WAIT = 0;
private NmsTemplateResourceFactory transactionalResourceFactory;
@@ -76,7 +82,7 @@ namespace Spring.Messaging.Nms.Core
private bool pubSubNoLocal = false;
private long receiveTimeout = DEFAULT_RECEIVE_TIMEOUT;
private long receiveTimeout = RECEIVE_TIMEOUT_NO_WAIT;
private bool explicitQosEnabled = false;
@@ -284,7 +290,7 @@ namespace Spring.Messaging.Nms.Core
}
/// <summary>
/// Gets or sets the receive timeout to use for recieve calls.
/// Gets or sets the receive timeout to use for recieve calls (in milliseconds)
/// </summary>
/// <remarks>The default is -1, which means no timeout.</remarks>
/// <value>The receive timeout.</value>
@@ -1064,9 +1070,9 @@ namespace Spring.Messaging.Nms.Core
if (resourceHolder != null && resourceHolder.HasTimeout)
{
timeout = Convert.ToInt64(resourceHolder.TimeToLiveInMilliseconds);
}
}
IMessage message = (timeout > 0)
? consumer.Receive(new TimeSpan(timeout))
? consumer.Receive(TimeSpan.FromMilliseconds(timeout))
: consumer.Receive();
if (session.Transacted)
{