Commit 9b7c3f56 authored by Savorboard's avatar Savorboard

add comment and fixed spell error.

parent 484f6b84
...@@ -32,20 +32,20 @@ namespace Microsoft.Extensions.DependencyInjection ...@@ -32,20 +32,20 @@ namespace Microsoft.Extensions.DependencyInjection
AddSubscribeServices(services); AddSubscribeServices(services);
// serializer and model binder //Serializer and model binder
services.TryAddSingleton<IContentSerializer, JsonContentSerializer>(); services.TryAddSingleton<IContentSerializer, JsonContentSerializer>();
services.TryAddSingleton<IConsumerServiceSelector, DefaultConsumerServiceSelector>(); services.TryAddSingleton<IConsumerServiceSelector, DefaultConsumerServiceSelector>();
services.TryAddSingleton<IModelBinderFactory, ModelBinderFactory>(); services.TryAddSingleton<IModelBinderFactory, ModelBinderFactory>();
services.TryAddSingleton<IConsumerInvokerFactory, ConsumerInvokerFactory>(); services.TryAddSingleton<IConsumerInvokerFactory, ConsumerInvokerFactory>();
services.TryAddSingleton<MethodMatcherCache>(); services.TryAddSingleton<MethodMatcherCache>();
//bootstrap //Bootstrapper and Processors
services.AddSingleton<IProcessingServer, ConsumerHandler>(); services.AddSingleton<IProcessingServer, ConsumerHandler>();
services.AddSingleton<IProcessingServer, CapProcessingServer>(); services.AddSingleton<IProcessingServer, CapProcessingServer>();
services.AddSingleton<IBootstrapper, DefaultBootstrapper>(); services.AddSingleton<IBootstrapper, DefaultBootstrapper>();
services.AddSingleton<IStateChanger, StateChanger>(); services.AddSingleton<IStateChanger, StateChanger>();
//Processors //Queue's message processor
services.AddTransient<PublishQueuer>(); services.AddTransient<PublishQueuer>();
services.AddTransient<SubscribeQueuer>(); services.AddTransient<SubscribeQueuer>();
services.AddTransient<FailedProcessor>(); services.AddTransient<FailedProcessor>();
......
...@@ -15,7 +15,7 @@ namespace DotNetCore.CAP ...@@ -15,7 +15,7 @@ namespace DotNetCore.CAP
/// otherwise you need to use overloaded method with IDbConnection and IDbTransaction. /// otherwise you need to use overloaded method with IDbConnection and IDbTransaction.
/// </para> /// </para>
/// </summary> /// </summary>
/// <typeparam name="T">The type of conetent object.</typeparam> /// <typeparam name="T">The type of content object.</typeparam>
/// <param name="name">the topic name or exchange router key.</param> /// <param name="name">the topic name or exchange router key.</param>
/// <param name="contentObj">message body content, that will be serialized of json.</param> /// <param name="contentObj">message body content, that will be serialized of json.</param>
/// <param name="callbackName">callback subscriber name</param> /// <param name="callbackName">callback subscriber name</param>
...@@ -28,7 +28,7 @@ namespace DotNetCore.CAP ...@@ -28,7 +28,7 @@ namespace DotNetCore.CAP
/// otherwise you need to use overloaded method with IDbConnection and IDbTransaction. /// otherwise you need to use overloaded method with IDbConnection and IDbTransaction.
/// </para> /// </para>
/// </summary> /// </summary>
/// <typeparam name="T">The type of conetent object.</typeparam> /// <typeparam name="T">The type of content object.</typeparam>
/// <param name="name">the topic name or exchange router key.</param> /// <param name="name">the topic name or exchange router key.</param>
/// <param name="contentObj">message body content, that will be serialized of json.</param> /// <param name="contentObj">message body content, that will be serialized of json.</param>
/// <param name="callbackName">callback subscriber name</param> /// <param name="callbackName">callback subscriber name</param>
......
...@@ -4,6 +4,7 @@ using System.Threading; ...@@ -4,6 +4,7 @@ using System.Threading;
namespace DotNetCore.CAP namespace DotNetCore.CAP
{ {
/// <inheritdoc />
/// <summary> /// <summary>
/// consumer client /// consumer client
/// </summary> /// </summary>
......
...@@ -8,7 +8,7 @@ ...@@ -8,7 +8,7 @@
/// <summary> /// <summary>
/// Create a new instance of <see cref="IConsumerClient" />. /// Create a new instance of <see cref="IConsumerClient" />.
/// </summary> /// </summary>
/// <param name="groupId"></param> /// <param name="groupId">message group number</param>
IConsumerClient Create(string groupId); IConsumerClient Create(string groupId);
} }
} }
\ No newline at end of file
namespace DotNetCore.CAP namespace DotNetCore.CAP
{ {
/// <summary>
/// Handler received message of subscribed.
/// </summary>
public interface IConsumerHandler : IProcessingServer public interface IConsumerHandler : IProcessingServer
{ {
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment