You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by jg...@apache.org on 2008/10/01 00:01:47 UTC
svn commit: r700594 -
/activemq/activemq-dotnet/Apache.NMS.EMS/trunk/src/main/csharp/MessageProducer.cs
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