Author: jgomes
Date: Tue Sep 30 15:01:47 2008
New Revision: 700594

URL: http://svn.apache.org/viewvc?rev=700594&view=rev
Log:
Set requestTimeout.

Modified:
    
activemq/activemq-dotnet/Apache.NMS.EMS/trunk/src/main/csharp/MessageProducer.cs

Modified: 
activemq/activemq-dotnet/Apache.NMS.EMS/trunk/src/main/csharp/MessageProducer.cs
URL: 
http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.EMS/trunk/src/main/csharp/MessageProducer.cs?rev=700594&r1=700593&r2=700594&view=diff
==============================================================================
--- 
activemq/activemq-dotnet/Apache.NMS.EMS/trunk/src/main/csharp/MessageProducer.cs
 (original)
+++ 
activemq/activemq-dotnet/Apache.NMS.EMS/trunk/src/main/csharp/MessageProducer.cs
 Tue Sep 30 15:01:47 2008
@@ -24,6 +24,7 @@
        {
                protected readonly Apache.NMS.EMS.Session nmsSession;
                public TIBCO.EMS.MessageProducer tibcoMessageProducer;
+               private TimeSpan requestTimeout = 
NMSConstants.defaultRequestTimeout;
                private bool closed = false;
                private bool disposed = false;
 
@@ -31,6 +32,7 @@
                {
                        this.nmsSession = session;
                        this.tibcoMessageProducer = producer;
+                       this.RequestTimeout = session.RequestTimeout;
                }
 
                ~MessageProducer()
@@ -130,8 +132,8 @@
                /// </summary>
                public TimeSpan RequestTimeout
                {
-                       get { return 
Apache.NMS.NMSConstants.defaultRequestTimeout; }
-                       set { }
+                       get { return requestTimeout; }
+                       set { this.requestTimeout = value; }
                }
 
                public byte Priority


Reply via email to