Browse Source

CorrelationIdOptions to AbpCorrelationIdOptions

pull/1919/head
Yunus Emre Kalkan 7 years ago
parent
commit
03815ea07e
  1. 6
      framework/src/Volo.Abp.AspNetCore/Volo/Abp/AspNetCore/Tracing/AbpCorrelationIdMiddleware.cs
  2. 4
      framework/src/Volo.Abp.AspNetCore/Volo/Abp/AspNetCore/Tracing/AspNetCoreCorrelationIdProvider.cs
  3. 2
      framework/src/Volo.Abp.Core/Volo/Abp/Tracing/AbpCorrelationIdOptions.cs
  4. 8
      framework/src/Volo.Abp.Http.Client/Volo/Abp/Http/Client/DynamicProxying/DynamicHttpProxyInterceptor.cs

6
framework/src/Volo.Abp.AspNetCore/Volo/Abp/AspNetCore/Tracing/AbpCorrelationIdMiddleware.cs

@ -8,10 +8,10 @@ namespace Volo.Abp.AspNetCore.Tracing
{ {
public class AbpCorrelationIdMiddleware : IMiddleware, ITransientDependency public class AbpCorrelationIdMiddleware : IMiddleware, ITransientDependency
{ {
private readonly CorrelationIdOptions _options; private readonly AbpCorrelationIdOptions _options;
private readonly ICorrelationIdProvider _correlationIdProvider; private readonly ICorrelationIdProvider _correlationIdProvider;
public AbpCorrelationIdMiddleware(IOptions<CorrelationIdOptions> options, public AbpCorrelationIdMiddleware(IOptions<AbpCorrelationIdOptions> options,
ICorrelationIdProvider correlationIdProvider) ICorrelationIdProvider correlationIdProvider)
{ {
_options = options.Value; _options = options.Value;
@ -34,7 +34,7 @@ namespace Volo.Abp.AspNetCore.Tracing
protected virtual void CheckAndSetCorrelationIdOnResponse( protected virtual void CheckAndSetCorrelationIdOnResponse(
HttpContext httpContext, HttpContext httpContext,
CorrelationIdOptions options, AbpCorrelationIdOptions options,
string correlationId) string correlationId)
{ {
if (httpContext.Response.HasStarted) if (httpContext.Response.HasStarted)

4
framework/src/Volo.Abp.AspNetCore/Volo/Abp/AspNetCore/Tracing/AspNetCoreCorrelationIdProvider.cs

@ -10,11 +10,11 @@ namespace Volo.Abp.AspNetCore.Tracing
public class AspNetCoreCorrelationIdProvider : ICorrelationIdProvider, ITransientDependency public class AspNetCoreCorrelationIdProvider : ICorrelationIdProvider, ITransientDependency
{ {
protected IHttpContextAccessor HttpContextAccessor { get; } protected IHttpContextAccessor HttpContextAccessor { get; }
protected CorrelationIdOptions Options { get; } protected AbpCorrelationIdOptions Options { get; }
public AspNetCoreCorrelationIdProvider( public AspNetCoreCorrelationIdProvider(
IHttpContextAccessor httpContextAccessor, IHttpContextAccessor httpContextAccessor,
IOptions<CorrelationIdOptions> options) IOptions<AbpCorrelationIdOptions> options)
{ {
HttpContextAccessor = httpContextAccessor; HttpContextAccessor = httpContextAccessor;
Options = options.Value; Options = options.Value;

2
framework/src/Volo.Abp.Core/Volo/Abp/Tracing/CorrelationIdOptions.cs → framework/src/Volo.Abp.Core/Volo/Abp/Tracing/AbpCorrelationIdOptions.cs

@ -1,6 +1,6 @@
namespace Volo.Abp.Tracing namespace Volo.Abp.Tracing
{ {
public class CorrelationIdOptions public class AbpCorrelationIdOptions
{ {
public string HttpHeaderName { get; set; } = "X-Correlation-Id"; public string HttpHeaderName { get; set; } = "X-Correlation-Id";

8
framework/src/Volo.Abp.Http.Client/Volo/Abp/Http/Client/DynamicProxying/DynamicHttpProxyInterceptor.cs

@ -31,7 +31,7 @@ namespace Volo.Abp.Http.Client.DynamicProxying
protected ICancellationTokenProvider CancellationTokenProvider { get; } protected ICancellationTokenProvider CancellationTokenProvider { get; }
protected ICorrelationIdProvider CorrelationIdProvider { get; } protected ICorrelationIdProvider CorrelationIdProvider { get; }
protected ICurrentTenant CurrentTenant { get; } protected ICurrentTenant CurrentTenant { get; }
protected CorrelationIdOptions CorrelationIdOptions { get; } protected AbpCorrelationIdOptions AbpCorrelationIdOptions { get; }
protected IDynamicProxyHttpClientFactory HttpClientFactory { get; } protected IDynamicProxyHttpClientFactory HttpClientFactory { get; }
protected IApiDescriptionFinder ApiDescriptionFinder { get; } protected IApiDescriptionFinder ApiDescriptionFinder { get; }
protected RemoteServiceOptions RemoteServiceOptions { get; } protected RemoteServiceOptions RemoteServiceOptions { get; }
@ -57,13 +57,13 @@ namespace Volo.Abp.Http.Client.DynamicProxying
IRemoteServiceHttpClientAuthenticator clientAuthenticator, IRemoteServiceHttpClientAuthenticator clientAuthenticator,
ICancellationTokenProvider cancellationTokenProvider, ICancellationTokenProvider cancellationTokenProvider,
ICorrelationIdProvider correlationIdProvider, ICorrelationIdProvider correlationIdProvider,
IOptions<CorrelationIdOptions> correlationIdOptions, IOptions<AbpCorrelationIdOptions> correlationIdOptions,
ICurrentTenant currentTenant) ICurrentTenant currentTenant)
{ {
CancellationTokenProvider = cancellationTokenProvider; CancellationTokenProvider = cancellationTokenProvider;
CorrelationIdProvider = correlationIdProvider; CorrelationIdProvider = correlationIdProvider;
CurrentTenant = currentTenant; CurrentTenant = currentTenant;
CorrelationIdOptions = correlationIdOptions.Value; AbpCorrelationIdOptions = correlationIdOptions.Value;
HttpClientFactory = httpClientFactory; HttpClientFactory = httpClientFactory;
ApiDescriptionFinder = apiDescriptionFinder; ApiDescriptionFinder = apiDescriptionFinder;
JsonSerializer = jsonSerializer; JsonSerializer = jsonSerializer;
@ -215,7 +215,7 @@ namespace Volo.Abp.Http.Client.DynamicProxying
} }
//CorrelationId //CorrelationId
requestMessage.Headers.Add(CorrelationIdOptions.HttpHeaderName, CorrelationIdProvider.Get()); requestMessage.Headers.Add(AbpCorrelationIdOptions.HttpHeaderName, CorrelationIdProvider.Get());
//TenantId //TenantId
if (CurrentTenant.Id.HasValue) if (CurrentTenant.Id.HasValue)

Loading…
Cancel
Save