activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jgo...@apache.org
Subject svn commit: r678933 - in /activemq/activemq-dotnet/Apache.NMS.MSMQ/trunk/src/main/csharp: Connection.cs Session.cs
Date Tue, 22 Jul 2008 22:29:35 GMT
Author: jgomes
Date: Tue Jul 22 15:29:35 2008
New Revision: 678933

URL: http://svn.apache.org/viewvc?rev=678933&view=rev
Log:
Added overloaded methods to take optional timeout parameter.

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=678933&r1=678932&r2=678933&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 Jul 22
15:29:35 2008
@@ -78,7 +78,13 @@
             CheckConnected();
             return new Session(this, mode);
         }
-        
+
+		public ISession CreateSession(AcknowledgementMode mode, TimeSpan responseTimoeout)
+		{
+			// Ignore: responseTimeout
+			return CreateSession(mode);
+		}
+
         public void Dispose()
         {
             closed = true;

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=678933&r1=678932&r2=678933&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 Jul 22 15:29:35
2008
@@ -53,25 +53,43 @@
         {
             return CreateProducer(null);
         }
-        
-        public IMessageProducer CreateProducer(IDestination destination)
+
+		public IMessageProducer CreateProducer(IDestination destination)
+		{
+			return new MessageProducer(this, (Destination) destination);
+		}
+
+        public IMessageProducer CreateProducer(IDestination destination, TimeSpan responseTimeout)
         {
-            return new MessageProducer(this, (Destination) destination);
+			// 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,
bool noLocal)
-        {
-			if (selector != null)
+		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)
 			{
 				throw new NotImplementedException("Selectors are not supported by MSQM");
 			}
@@ -79,11 +97,22 @@
             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 IQueue GetQueue(string name)
         {
             return new Queue(name);



Mime
View raw message