Remove MaxReceiveWaitTime property from processor (#15931)

* Remove MaxReceiveWaitTime property from processor * Export API
Azure · Oct 13, 2020 · 3a6681c · 3a6681c
1 parent 51f9fad
commit 3a6681c
Show file tree

Hide file tree

Showing 4 changed files with 0 additions and 12 deletions.
diff --git a/sdk/servicebus/Azure.Messaging.ServiceBus/api/Azure.Messaging.ServiceBus.netstandard2.0.cs b/sdk/servicebus/Azure.Messaging.ServiceBus/api/Azure.Messaging.ServiceBus.netstandard2.0.cs
@@ -198,7 +198,6 @@ protected ServiceBusProcessor() { }
         public bool IsProcessing { get { throw null; } }
         public System.TimeSpan MaxAutoLockRenewalDuration { get { throw null; } }
         public int MaxConcurrentCalls { get { throw null; } }
-        public System.TimeSpan? MaxReceiveWaitTime { get { throw null; } }
         public int PrefetchCount { get { throw null; } }
         public Azure.Messaging.ServiceBus.ReceiveMode ReceiveMode { get { throw null; } }
         public event System.Func<Azure.Messaging.ServiceBus.ProcessErrorEventArgs, System.Threading.Tasks.Task> ProcessErrorAsync { add { } remove { } }
@@ -376,7 +375,6 @@ protected ServiceBusSessionProcessor() { }
         public System.TimeSpan MaxAutoLockRenewalDuration { get { throw null; } }
         public int MaxConcurrentCallsPerSession { get { throw null; } }
         public int MaxConcurrentSessions { get { throw null; } }
-        public System.TimeSpan? MaxReceiveWaitTime { get { throw null; } }
         public int PrefetchCount { get { throw null; } }
         public Azure.Messaging.ServiceBus.ReceiveMode ReceiveMode { get { throw null; } }
         public event System.Func<Azure.Messaging.ServiceBus.ProcessErrorEventArgs, System.Threading.Tasks.Task> ProcessErrorAsync { add { } remove { } }

diff --git a/sdk/servicebus/Azure.Messaging.ServiceBus/src/Processor/ServiceBusProcessor.cs b/sdk/servicebus/Azure.Messaging.ServiceBus/src/Processor/ServiceBusProcessor.cs
@@ -111,11 +111,6 @@ public class ServiceBusProcessor : IAsyncDisposable
         /// <value>The maximum number of concurrent calls to the message handler.</value>
         public int MaxConcurrentCalls { get; }
 
-        /// <summary>
-        /// Gets the maximum amount of time to wait for each Receive call using the processor's underlying receiver. If not specified, the <see cref="ServiceBusRetryOptions.TryTimeout"/> will be used.
-        /// </summary>
-        public TimeSpan? MaxReceiveWaitTime { get; }
-
         /// <summary>
         /// Gets a value that indicates whether the processor should automatically
         /// complete messages after the message handler has completed processing. If the
@@ -223,7 +218,6 @@ internal ServiceBusProcessor(
                 maxAcceptSessions,
                 maxAcceptSessions);
 
-            MaxReceiveWaitTime = _options.MaxReceiveWaitTime;
             AutoComplete = _options.AutoComplete;
 
             EntityPath = entityPath;

diff --git a/sdk/servicebus/Azure.Messaging.ServiceBus/src/Processor/ServiceBusSessionProcessor.cs b/sdk/servicebus/Azure.Messaging.ServiceBus/src/Processor/ServiceBusSessionProcessor.cs
@@ -82,9 +82,6 @@ public class ServiceBusSessionProcessor : IAsyncDisposable
         /// <inheritdoc cref="ServiceBusProcessor.FullyQualifiedNamespace"/>
         public string FullyQualifiedNamespace => _innerProcessor.FullyQualifiedNamespace;
 
-        /// <inheritdoc cref="ServiceBusProcessor.MaxReceiveWaitTime"/>
-        public TimeSpan? MaxReceiveWaitTime => _innerProcessor.MaxReceiveWaitTime;
-
         internal ServiceBusSessionProcessor(
             ServiceBusConnection connection,
             string entityPath,

diff --git a/sdk/servicebus/Azure.Messaging.ServiceBus/tests/Processor/ProcessorTests.cs b/sdk/servicebus/Azure.Messaging.ServiceBus/tests/Processor/ProcessorTests.cs
@@ -145,7 +145,6 @@ public void ProcessorOptionsSetOnClient()
             Assert.AreEqual(options.ReceiveMode, processor.ReceiveMode);
             Assert.AreEqual(options.MaxAutoLockRenewalDuration, processor.MaxAutoLockRenewalDuration);
             Assert.AreEqual(fullyQualifiedNamespace, processor.FullyQualifiedNamespace);
-            Assert.AreEqual(options.MaxReceiveWaitTime, processor.MaxReceiveWaitTime);
             Assert.IsFalse(processor.IsClosed);
             Assert.IsFalse(processor.IsProcessing);
         }