Browse Source

modify extensions

master
yangxiaodong 7 years ago
parent
commit
6cd228676c
3 changed files with 3 additions and 17 deletions
  1. +1
    -1
      src/Cap.Consistency/Extensions/BuilderExtensions.cs
  2. +0
    -12
      src/Cap.Consistency/Extensions/ConsistencyOptions.cs
  3. +2
    -4
      src/Cap.Consistency/Extensions/ServiceCollectionExtensions.cs

+ 1
- 1
src/Cap.Consistency/Extensions/BuilderExtensions.cs View File

@@ -31,7 +31,7 @@ namespace Microsoft.AspNetCore.Builder


var context = new TopicRouteContext(); var context = new TopicRouteContext();


router.RouteAsync(context).Wait();
router.RouteAsync(context);


return app; return app;
} }


+ 0
- 12
src/Cap.Consistency/Extensions/ConsistencyOptions.cs View File

@@ -1,12 +0,0 @@
using Cap.Consistency;

namespace Microsoft.AspNetCore.Builder
{
/// <summary>
/// Represents all the options you can use to configure the system.
/// </summary>
public class ConsistencyOptions
{
public string BrokerUrlList { get; set; } = "localhost:9092";
}
}

+ 2
- 4
src/Cap.Consistency/Extensions/ServiceCollectionExtensions.cs View File

@@ -19,7 +19,7 @@ namespace Microsoft.Extensions.DependencyInjection
/// <returns>An <see cref="ConsistencyBuilder"/> for application services.</returns> /// <returns>An <see cref="ConsistencyBuilder"/> for application services.</returns>
public static ConsistencyBuilder AddConsistency<TMessage>(this IServiceCollection services) public static ConsistencyBuilder AddConsistency<TMessage>(this IServiceCollection services)
where TMessage : ConsistencyMessage { where TMessage : ConsistencyMessage {
return services.AddConsistency<TMessage>(setupAction: null);
return services.AddConsistency<TMessage>(x => new ConsistencyOptions());
} }


/// <summary> /// <summary>
@@ -34,9 +34,7 @@ namespace Microsoft.Extensions.DependencyInjection


services.TryAddScoped<ConsistencyMessageManager<TMessage>, ConsistencyMessageManager<TMessage>>(); services.TryAddScoped<ConsistencyMessageManager<TMessage>, ConsistencyMessageManager<TMessage>>();


if (setupAction != null) {
services.Configure(setupAction);
}
services.Configure(setupAction);


return new ConsistencyBuilder(typeof(TMessage), services); return new ConsistencyBuilder(typeof(TMessage), services);
} }


Loading…
Cancel
Save