Skip to content

Commit 5576780

Browse files
committed
Ensuring an app level middleware pipeline is registered
1 parent c2825fc commit 5576780

File tree

2 files changed

+6
-0
lines changed

2 files changed

+6
-0
lines changed

src/WebJobs.Script.WebHost/Middleware/JobHostMiddleware/DefaultMiddlewarePipeline.cs

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -11,11 +11,15 @@ namespace Microsoft.Azure.WebJobs.Script.Middleware
1111
{
1212
internal class DefaultMiddlewarePipeline : IJobHostMiddlewarePipeline
1313
{
14+
private static Lazy<IJobHostMiddlewarePipeline> _emptyPipeline = new Lazy<IJobHostMiddlewarePipeline>(() => new DefaultMiddlewarePipeline(Array.Empty<IJobHostHttpMiddleware>()));
15+
1416
public DefaultMiddlewarePipeline(IEnumerable<IJobHostHttpMiddleware> middleware)
1517
{
1618
Pipeline = BuildPipeline(middleware);
1719
}
1820

21+
public static IJobHostMiddlewarePipeline Empty => _emptyPipeline.Value;
22+
1923
public RequestDelegate Pipeline { get; }
2024

2125
private RequestDelegate BuildPipeline(IEnumerable<IJobHostHttpMiddleware> middleware)

src/WebJobs.Script.WebHost/WebHostServiceCollectionExtensions.cs

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -7,6 +7,7 @@
77
using Microsoft.Azure.WebJobs.Extensions.Http;
88
using Microsoft.Azure.WebJobs.Script.Config;
99
using Microsoft.Azure.WebJobs.Script.Diagnostics;
10+
using Microsoft.Azure.WebJobs.Script.Middleware;
1011
using Microsoft.Azure.WebJobs.Script.Rpc;
1112
using Microsoft.Azure.WebJobs.Script.WebHost.Configuration;
1213
using Microsoft.Azure.WebJobs.Script.WebHost.ContainerManagement;
@@ -127,6 +128,7 @@ public static void AddWebJobsScriptHost(this IServiceCollection services, IConfi
127128
services.ConfigureOptions<LanguageWorkerOptionsSetup>();
128129

129130
services.TryAddSingleton<IDependencyValidator, DependencyValidator>();
131+
services.TryAddSingleton<IJobHostMiddlewarePipeline>(s => DefaultMiddlewarePipeline.Empty);
130132
}
131133

132134
private static void AddStandbyServices(this IServiceCollection services)

0 commit comments

Comments
 (0)