Adding a couple tests

Azure · Feb 21, 2017 · bd5891d · bd5891d
1 parent 5c14431
commit bd5891d
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 2 deletions.
diff --git a/test/Microsoft.Azure.WebJobs.Host.EndToEndTests/AsyncChainEndToEndTests.cs b/test/Microsoft.Azure.WebJobs.Host.EndToEndTests/AsyncChainEndToEndTests.cs
@@ -617,9 +617,11 @@ public QueueProcessor Create(QueueProcessorFactoryContext context)
                 // demonstrates how queue options can be customized
                 context.Queue.EncodeMessage = true;
 
-                // demonstrates how batch processing behavior can be customized
+                // demonstrates how batch processing behavior and other knobs
+                // can be customized
                 context.BatchSize = 30;
                 context.NewBatchThreshold = 100;
+                context.MaxPollingInterval = TimeSpan.FromSeconds(15);
 
                 CustomQueueProcessor processor = new CustomQueueProcessor(context);
                 CustomQueueProcessors.Add(processor);

diff --git a/test/Microsoft.Azure.WebJobs.Host.FunctionalTests/Queues/QueueProcessorTests.cs b/test/Microsoft.Azure.WebJobs.Host.FunctionalTests/Queues/QueueProcessorTests.cs
@@ -42,7 +42,8 @@ public void Constructor_DefaultsValues()
                 BatchSize = 32,
                 MaxDequeueCount = 2,
                 NewBatchThreshold = 100,
-                VisibilityTimeout = TimeSpan.FromSeconds(30)
+                VisibilityTimeout = TimeSpan.FromSeconds(30),
+                MaxPollingInterval = TimeSpan.FromSeconds(15)
             };
             QueueProcessorFactoryContext context = new QueueProcessorFactoryContext(_queue, _trace, config);
             QueueProcessor localProcessor = new QueueProcessor(context);
@@ -51,6 +52,7 @@ public void Constructor_DefaultsValues()
             Assert.Equal(config.MaxDequeueCount, localProcessor.MaxDequeueCount);
             Assert.Equal(config.NewBatchThreshold, localProcessor.NewBatchThreshold);
             Assert.Equal(config.VisibilityTimeout, localProcessor.VisibilityTimeout);
+            Assert.Equal(config.MaxPollingInterval, localProcessor.MaxPollingInterval);
         }
 
         [Fact]

diff --git a/test/Microsoft.Azure.WebJobs.Host.UnitTests/Queues/QueueProcessorFactoryContextTests.cs b/test/Microsoft.Azure.WebJobs.Host.UnitTests/Queues/QueueProcessorFactoryContextTests.cs
@@ -30,6 +30,7 @@ public void Constructor_DefaultsValues()
             Assert.Equal(queuesConfig.BatchSize, context.BatchSize);
             Assert.Equal(queuesConfig.NewBatchThreshold, context.NewBatchThreshold);
             Assert.Equal(queuesConfig.MaxDequeueCount, context.MaxDequeueCount);
+            Assert.Equal(queuesConfig.MaxPollingInterval, context.MaxPollingInterval);
         }
     }
 }