activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jgo...@apache.org
Subject svn commit: r700586 - in /activemq/activemq-dotnet: Apache.NMS.ActiveMQ/trunk/src/main/csharp/Session.cs Apache.NMS.EMS/trunk/src/main/csharp/Session.cs
Date Tue, 30 Sep 2008 21:29:44 GMT
Author: jgomes
Date: Tue Sep 30 14:29:43 2008
New Revision: 700586

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

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

Modified: activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Session.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Session.cs?rev=700586&r1=700585&r2=700586&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Session.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/main/csharp/Session.cs Tue Sep
30 14:29:43 2008
@@ -407,7 +407,7 @@
 
 		// Properties
 
-		private TimeSpan requestTimeout;
+		private TimeSpan requestTimeout = Apache.NMS.NMSConstants.defaultRequestTimeout;
 		public TimeSpan RequestTimeout
 		{
 			get { return this.requestTimeout; }

Modified: activemq/activemq-dotnet/Apache.NMS.EMS/trunk/src/main/csharp/Session.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.EMS/trunk/src/main/csharp/Session.cs?rev=700586&r1=700585&r2=700586&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.EMS/trunk/src/main/csharp/Session.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.EMS/trunk/src/main/csharp/Session.cs Tue Sep 30 14:29:43
2008
@@ -18,18 +18,18 @@
 
 namespace Apache.NMS.EMS
 {
-    /// <summary>
+	/// <summary>
 	/// Represents a NMS session to TIBCO.
-    /// </summary>
-    public class Session : Apache.NMS.ISession
-    {
-    	public readonly TIBCO.EMS.Session tibcoSession;
-    	private bool closed = false;
-    	private bool disposed = false;
-
-        public Session(TIBCO.EMS.Session session)
-        {
-        	this.tibcoSession = session;
+	/// </summary>
+	public class Session : Apache.NMS.ISession
+	{
+		public readonly TIBCO.EMS.Session tibcoSession;
+		private bool closed = false;
+		private bool disposed = false;
+
+		public Session(TIBCO.EMS.Session session)
+		{
+			this.tibcoSession = session;
 		}
 
 		~Session()
@@ -40,44 +40,44 @@
 		#region ISession Members
 
 		public Apache.NMS.IMessageProducer CreateProducer()
-        {
-            return CreateProducer(null);
-        }
+		{
+			return CreateProducer(null);
+		}
 
 		public Apache.NMS.IMessageProducer CreateProducer(Apache.NMS.IDestination destination)
-        {
+		{
 			Apache.NMS.EMS.Destination destinationObj = (Apache.NMS.EMS.Destination) destination;
 
 			return EMSConvert.ToNMSMessageProducer(this, this.tibcoSession.CreateProducer(destinationObj.tibcoDestination));
-        }
+		}
 
 		public Apache.NMS.IMessageConsumer CreateConsumer(Apache.NMS.IDestination destination)
-        {
+		{
 			Apache.NMS.EMS.Destination destinationObj = (Apache.NMS.EMS.Destination) destination;
 
 			return EMSConvert.ToNMSMessageConsumer(this, this.tibcoSession.CreateConsumer(destinationObj.tibcoDestination));
-        }
+		}
 
 		public Apache.NMS.IMessageConsumer CreateConsumer(Apache.NMS.IDestination destination,
string selector)
-        {
+		{
 			Apache.NMS.EMS.Destination destinationObj = (Apache.NMS.EMS.Destination) destination;
 
 			return EMSConvert.ToNMSMessageConsumer(this, this.tibcoSession.CreateConsumer(destinationObj.tibcoDestination,
selector));
 		}
 
 		public Apache.NMS.IMessageConsumer CreateConsumer(Apache.NMS.IDestination destination,
string selector, bool noLocal)
-        {
+		{
 			Apache.NMS.EMS.Destination destinationObj = (Apache.NMS.EMS.Destination) destination;
 
 			return EMSConvert.ToNMSMessageConsumer(this, this.tibcoSession.CreateConsumer(destinationObj.tibcoDestination,
selector, noLocal));
-        }
+		}
 
 		public Apache.NMS.IMessageConsumer CreateDurableConsumer(Apache.NMS.ITopic destination,
string name, string selector, bool noLocal)
-        {
+		{
 			Apache.NMS.EMS.Topic topicObj = (Apache.NMS.EMS.Topic) destination;
 
 			return EMSConvert.ToNMSMessageConsumer(this, this.tibcoSession.CreateDurableSubscriber(topicObj.tibcoTopic,
name, selector, noLocal));
-        }
+		}
 
 		public void DeleteDurableConsumer(string name)
 		{
@@ -85,52 +85,52 @@
 		}
 
 		public Apache.NMS.IQueue GetQueue(string name)
-        {
+		{
 			return EMSConvert.ToNMSQueue(this.tibcoSession.CreateQueue(name));
-        }
+		}
 
 		public Apache.NMS.ITopic GetTopic(string name)
-        {
+		{
 			return EMSConvert.ToNMSTopic(this.tibcoSession.CreateTopic(name));
-        }
+		}
 
 		public Apache.NMS.ITemporaryQueue CreateTemporaryQueue()
-        {
+		{
 			return EMSConvert.ToNMSTemporaryQueue(this.tibcoSession.CreateTemporaryQueue());
-        }
+		}
 
 		public Apache.NMS.ITemporaryTopic CreateTemporaryTopic()
-        {
+		{
 			return EMSConvert.ToNMSTemporaryTopic(this.tibcoSession.CreateTemporaryTopic());
-        }
+		}
 
 		public Apache.NMS.IMessage CreateMessage()
-        {
+		{
 			return EMSConvert.ToNMSMessage(this.tibcoSession.CreateMessage());
-        }
+		}
 
 		public Apache.NMS.ITextMessage CreateTextMessage()
-        {
+		{
 			return EMSConvert.ToNMSTextMessage(this.tibcoSession.CreateTextMessage());
-        }
+		}
 
 		public Apache.NMS.ITextMessage CreateTextMessage(string text)
-        {
+		{
 			return EMSConvert.ToNMSTextMessage(this.tibcoSession.CreateTextMessage(text));
-        }
+		}
 
 		public Apache.NMS.IMapMessage CreateMapMessage()
-        {
+		{
 			return EMSConvert.ToNMSMapMessage(this.tibcoSession.CreateMapMessage());
-        }
+		}
 
 		public Apache.NMS.IBytesMessage CreateBytesMessage()
-        {
+		{
 			return EMSConvert.ToNMSBytesMessage(this.tibcoSession.CreateBytesMessage());
-        }
+		}
 
 		public Apache.NMS.IBytesMessage CreateBytesMessage(byte[] body)
-        {
+		{
 			Apache.NMS.IBytesMessage bytesMessage = CreateBytesMessage();
 
 			if(null != bytesMessage)
@@ -139,46 +139,47 @@
 			}
 
 			return bytesMessage;
-        }
+		}
 
 		public Apache.NMS.IObjectMessage CreateObjectMessage(Object body)
 		{
 			return EMSConvert.ToNMSObjectMessage(this.tibcoSession.CreateObjectMessage(body));
 		}
 		
-        public void Commit()
-        {
+		public void Commit()
+		{
 			this.tibcoSession.Commit();
-        }
-        
-        public void Rollback()
-        {
+		}
+		
+		public void Rollback()
+		{
 			this.tibcoSession.Rollback();
-        }
-        
-        // Properties
+		}
+		
+		// Properties
 
 		/// <summary>
 		/// The default timeout for network requests.
 		/// </summary>
+		private TimeSpan requestTimeout = Apache.NMS.NMSConstants.defaultRequestTimeout;
 		public TimeSpan RequestTimeout
 		{
-			get { return Apache.NMS.NMSConstants.defaultRequestTimeout; }
-			set { }
+			get { return this.requestTimeout; }
+			set { this.requestTimeout = value; }
 		}
 		
 		public bool Transacted
-        {
-            get { return this.tibcoSession.Transacted; }
-        }
+		{
+			get { return this.tibcoSession.Transacted; }
+		}
 
 		public Apache.NMS.AcknowledgementMode AcknowledgementMode
-        {
-            get { return EMSConvert.ToAcknowledgementMode(this.tibcoSession.SessionAcknowledgeMode);
}
-        }
+		{
+			get { return EMSConvert.ToAcknowledgementMode(this.tibcoSession.SessionAcknowledgeMode);
}
+		}
 
-        public void Close()
-        {
+		public void Close()
+		{
 			lock(this)
 			{
 				if(closed)
@@ -189,7 +190,7 @@
 				this.tibcoSession.Close();
 				closed = true;
 			}
-        }
+		}
 
 		#endregion
 



Mime
View raw message