Author: tabish
Date: Mon Dec 20 15:43:19 2010
New Revision: 1051149
URL: http://svn.apache.org/viewvc?rev=1051149&view=rev
Log:
fix for: https://issues.apache.org/jira/browse/AMQNET-297
Modified:
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/RequestTimedOutException.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Transport/FutureResponse.cs
Modified:
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/RequestTimedOutException.cs
URL:
http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/RequestTimedOutException.cs?rev=1051149&r1=1051148&r2=1051149&view=diff
==============================================================================
---
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/RequestTimedOutException.cs
(original)
+++
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/RequestTimedOutException.cs
Mon Dec 20 15:43:19 2010
@@ -28,10 +28,15 @@ namespace Apache.NMS.ActiveMQ
public class RequestTimedOutException : IOException
{
public RequestTimedOutException()
- : base("IO Exception failed with missing exception log")
+ : base("Synchronous Request Timed out")
{
}
+ public RequestTimedOutException(TimeSpan interval)
+ : base("Synchronous Request Timed out after [" +
interval.TotalMilliseconds + "] milliseconds")
+ {
+ }
+
public RequestTimedOutException(String msg)
: base(msg)
{
Modified:
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Transport/FutureResponse.cs
URL:
http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Transport/FutureResponse.cs?rev=1051149&r1=1051148&r2=1051149&view=diff
==============================================================================
---
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Transport/FutureResponse.cs
(original)
+++
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Transport/FutureResponse.cs
Mon Dec 20 15:43:19 2010
@@ -54,7 +54,7 @@ namespace Apache.NMS.ActiveMQ.Transport
{
if(!latch.await(maxWait) && response ==
null)
{
- throw new
RequestTimedOutException();
+ throw new
RequestTimedOutException(maxWait);
}
}
catch(RequestTimedOutException e)
