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/07/23 00:24:20 UTC
svn commit: r678932 - in
/activemq/activemq-dotnet/Apache.NMS.EMS/trunk/src/main/csharp:
Connection.cs Session.cs
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));