activemq-commits mailing list archives

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

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

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

Modified: activemq/activemq-dotnet/Apache.NMS.EMS/trunk/src/main/csharp/Connection.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.EMS/trunk/src/main/csharp/Connection.cs?rev=678932&r1=678931&r2=678932&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.EMS/trunk/src/main/csharp/Connection.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.EMS/trunk/src/main/csharp/Connection.cs Tue Jul 22
15:24:19 2008
@@ -97,6 +97,12 @@
 			                                                  EMSConvert.ToSessionMode(mode)));
 		}
 
+		public Apache.NMS.ISession CreateSession(Apache.NMS.AcknowledgementMode mode, TimeSpan
requestTimeout)
+		{
+			// Ignore: requestTimeout
+			return CreateSession(mode);
+		}
+
 		public void Close()
 		{
 			lock(this)

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=678932&r1=678931&r2=678932&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 Jul 22 15:24:19
2008
@@ -51,6 +51,12 @@
 			return EMSConvert.ToNMSMessageProducer(this, this.tibcoSession.CreateProducer(destinationObj.tibcoDestination));
         }
 
+		public Apache.NMS.IMessageProducer CreateProducer(Apache.NMS.IDestination destination,
TimeSpan requestTimeout)
+		{
+			// Ignore: requestTimeout
+			return CreateProducer(destination);
+		}
+
 		public Apache.NMS.IMessageConsumer CreateConsumer(Apache.NMS.IDestination destination)
         {
 			Apache.NMS.EMS.Destination destinationObj = (Apache.NMS.EMS.Destination) destination;
@@ -58,6 +64,12 @@
 			return EMSConvert.ToNMSMessageConsumer(this, this.tibcoSession.CreateConsumer(destinationObj.tibcoDestination));
         }
 
+		public Apache.NMS.IMessageConsumer CreateConsumer(Apache.NMS.IDestination destination,
TimeSpan requestTimeout)
+		{
+			// Ignore: requestTimeout
+			return CreateConsumer(destination);
+		}
+
 		public Apache.NMS.IMessageConsumer CreateConsumer(Apache.NMS.IDestination destination,
string selector)
         {
 			Apache.NMS.EMS.Destination destinationObj = (Apache.NMS.EMS.Destination) destination;
@@ -65,6 +77,12 @@
 			return EMSConvert.ToNMSMessageConsumer(this, this.tibcoSession.CreateConsumer(destinationObj.tibcoDestination,
selector));
 		}
 
+		public Apache.NMS.IMessageConsumer CreateConsumer(Apache.NMS.IDestination destination,
string selector, TimeSpan requestTimeout)
+		{
+			// Ignore: requestTimeout
+			return CreateConsumer(destination, selector);
+		}
+
 		public Apache.NMS.IMessageConsumer CreateConsumer(Apache.NMS.IDestination destination,
string selector, bool noLocal)
         {
 			Apache.NMS.EMS.Destination destinationObj = (Apache.NMS.EMS.Destination) destination;
@@ -72,6 +90,12 @@
 			return EMSConvert.ToNMSMessageConsumer(this, this.tibcoSession.CreateConsumer(destinationObj.tibcoDestination,
selector, noLocal));
         }
 
+		public Apache.NMS.IMessageConsumer CreateConsumer(Apache.NMS.IDestination destination,
string selector, bool noLocal, TimeSpan requestTimeout)
+		{
+			// Ignore: requestTimeout
+			return CreateConsumer(destination, 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;
@@ -79,6 +103,12 @@
 			return EMSConvert.ToNMSMessageConsumer(this, this.tibcoSession.CreateDurableSubscriber(topicObj.tibcoTopic,
name, selector, noLocal));
         }
 
+		public Apache.NMS.IMessageConsumer CreateDurableConsumer(Apache.NMS.ITopic destination,
string name, string selector, bool noLocal, TimeSpan requestTimeout)
+		{
+			// Ignore: requestTimeout
+			return CreateDurableConsumer(destination, name, selector, noLocal);
+		}
+
 		public Apache.NMS.IQueue GetQueue(string name)
         {
 			return EMSConvert.ToNMSQueue(this.tibcoSession.CreateQueue(name));



Mime
View raw message