activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jgo...@apache.org
Subject svn commit: r687186 - in /activemq/activemq-dotnet/Apache.NMS.MSMQ/trunk/src/main/csharp: Connection.cs Session.cs
Date Tue, 19 Aug 2008 22:18:01 GMT
Author: jgomes
Date: Tue Aug 19 15:18:00 2008
New Revision: 687186

URL: http://svn.apache.org/viewvc?rev=687186&view=rev
Log:
Changed IConnection, ISession to have RequestTimeout property similar to IMessageProducer.
Fixes [AMQNET-89]. (See https://issues.apache.org/activemq/browse/AMQNET-89)

Modified:
    activemq/activemq-dotnet/Apache.NMS.MSMQ/trunk/src/main/csharp/Connection.cs
    activemq/activemq-dotnet/Apache.NMS.MSMQ/trunk/src/main/csharp/Session.cs

Modified: activemq/activemq-dotnet/Apache.NMS.MSMQ/trunk/src/main/csharp/Connection.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.MSMQ/trunk/src/main/csharp/Connection.cs?rev=687186&r1=687185&r2=687186&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.MSMQ/trunk/src/main/csharp/Connection.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.MSMQ/trunk/src/main/csharp/Connection.cs Tue Aug 19
15:18:00 2008
@@ -79,18 +79,21 @@
             return new Session(this, mode);
         }
 
-		public ISession CreateSession(AcknowledgementMode mode, TimeSpan responseTimoeout)
-		{
-			// Ignore: responseTimeout
-			return CreateSession(mode);
-		}
-
         public void Dispose()
         {
             closed = true;
         }
-        
-        public AcknowledgementMode AcknowledgementMode
+
+		/// <summary>
+		/// The default timeout for network requests.
+		/// </summary>
+		public TimeSpan RequestTimeout
+		{
+			get { return NMSConstants.defaultRequestTimeout; }
+			set { }
+		}
+
+		public AcknowledgementMode AcknowledgementMode
         {
             get { return acknowledgementMode; }
             set { acknowledgementMode = value; }

Modified: activemq/activemq-dotnet/Apache.NMS.MSMQ/trunk/src/main/csharp/Session.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.MSMQ/trunk/src/main/csharp/Session.cs?rev=687186&r1=687185&r2=687186&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.MSMQ/trunk/src/main/csharp/Session.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.MSMQ/trunk/src/main/csharp/Session.cs Tue Aug 19 15:18:00
2008
@@ -59,34 +59,16 @@
 			return new MessageProducer(this, (Destination) destination);
 		}
 
-		public IMessageProducer CreateProducer(IDestination destination, TimeSpan responseTimeout)
-		{
-			// Ignore: responseTimeout
-			return CreateProducer(destination);
-		}
-		
 		public IMessageConsumer CreateConsumer(IDestination destination)
 		{
 			return CreateConsumer(destination, null);
 		}
 
-		public IMessageConsumer CreateConsumer(IDestination destination, TimeSpan responseTimeout)
-		{
-			// Ignore: responseTimeout
-			return CreateConsumer(destination);
-		}
-		
 		public IMessageConsumer CreateConsumer(IDestination destination, string selector)
 		{
 			return CreateConsumer(destination, selector, false);
 		}
 
-		public IMessageConsumer CreateConsumer(IDestination destination, string selector, TimeSpan
responseTimeout)
-		{
-			// Ignore: responseTimeout
-			return CreateConsumer(destination, selector);
-		}
-
 		public IMessageConsumer CreateConsumer(IDestination destination, string selector, bool
noLocal)
 		{
 			if(selector != null)
@@ -97,33 +79,16 @@
 			return new MessageConsumer(this, acknowledgementMode, queue);
 		}
 
-		public IMessageConsumer CreateConsumer(IDestination destination, string selector, bool
noLocal, TimeSpan responseTimeout)
-		{
-			// Ignore: responseTimeout
-			return CreateConsumer(destination, selector, noLocal);
-		}
-
 		public IMessageConsumer CreateDurableConsumer(ITopic destination, string name, string selector,
bool noLocal)
 		{
 			throw new NotImplementedException("Durable Topic subscribers are not supported by MSMQ");
 		}
 
-		public IMessageConsumer CreateDurableConsumer(ITopic destination, string name, string selector,
bool noLocal, TimeSpan responseTimeout)
-		{
-			return CreateDurableConsumer(destination, name, selector, noLocal);
-		}
-
 		public void DeleteDurableConsumer(string name)
 		{
 			throw new NotImplementedException("Durable Topic subscribers are not supported by MSMQ");
 		}
 
-		public void DeleteDurableConsumer(string name, TimeSpan requestTimeout)
-		{
-			// Ignore: requestTimeout
-			DeleteDurableConsumer(name);
-		}
-
 		public IQueue GetQueue(string name)
 		{
 			return new Queue(name);
@@ -210,7 +175,16 @@
 		{
 			get { return connection; }
 		}
-		
+
+		/// <summary>
+		/// The default timeout for network requests.
+		/// </summary>
+		public TimeSpan RequestTimeout
+		{
+			get { return NMSConstants.defaultRequestTimeout; }
+			set { }
+		}
+
 		public bool Transacted
 		{
 			get { return acknowledgementMode == AcknowledgementMode.Transactional; }



Mime
View raw message