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; }
