rename class

.gitignore

@@ -28,3 +28,4 @@ project.lock.json
 .vs
 .build/
 .testPublish/
+/src/Cap.Consistency/obj/Debug/netstandard1.6

Cap.sln

@@ -14,6 +14,8 @@ Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "Solution Items", "Solution
 EndProject
 Project("{8BB2217D-0F2D-49D1-97BC-3654ED321F3B}") = "Cap.Consistency", "src\Cap.Consistency\Cap.Consistency.xproj", "{E8AF8611-0EA4-4B19-BC48-87C57A87DC66}"
 EndProject
+Project("{8BB2217D-0F2D-49D1-97BC-3654ED321F3B}") = "Cap.Consistency.Test", "test\Cap.Consistency.Test\Cap.Consistency.Test.xproj", "{3A444CF8-1611-407F-8D32-5D0CDC3DD49D}"
+EndProject
 Global
 	GlobalSection(SolutionConfigurationPlatforms) = preSolution
 		Debug|Any CPU = Debug|Any CPU
@@ -24,11 +26,16 @@ Global
 		{E8AF8611-0EA4-4B19-BC48-87C57A87DC66}.Debug|Any CPU.Build.0 = Debug|Any CPU
 		{E8AF8611-0EA4-4B19-BC48-87C57A87DC66}.Release|Any CPU.ActiveCfg = Release|Any CPU
 		{E8AF8611-0EA4-4B19-BC48-87C57A87DC66}.Release|Any CPU.Build.0 = Release|Any CPU
+		{3A444CF8-1611-407F-8D32-5D0CDC3DD49D}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{3A444CF8-1611-407F-8D32-5D0CDC3DD49D}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{3A444CF8-1611-407F-8D32-5D0CDC3DD49D}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{3A444CF8-1611-407F-8D32-5D0CDC3DD49D}.Release|Any CPU.Build.0 = Release|Any CPU
 	EndGlobalSection
 	GlobalSection(SolutionProperties) = preSolution
 		HideSolutionNode = FALSE
 	EndGlobalSection
 	GlobalSection(NestedProjects) = preSolution
 		{E8AF8611-0EA4-4B19-BC48-87C57A87DC66} = {9B2AE124-6636-4DE9-83A3-70360DABD0C4}
+		{3A444CF8-1611-407F-8D32-5D0CDC3DD49D} = {C09CDAB0-6DD4-46E9-B7F3-3EF2A4741EA0}
 	EndGlobalSection
 EndGlobal

src/Cap.Consistency/BuilderExtensions.cs

@@ -6,12 +6,12 @@ using System;
 namespace Microsoft.AspNetCore.Builder
 {
     /// <summary>
-    /// KafkaConsostence extensions for <see cref="IApplicationBuilder"/>
+    /// Consistence extensions for <see cref="IApplicationBuilder"/>
     /// </summary>
     public static class BuilderExtensions
     {
         /// <summary>
-        /// Enables KafkaConsistence for the current application
+        /// Enables Consistence for the current application
         /// </summary>
         /// <param name="app">The <see cref="IApplicationBuilder"/> instance this method extends.</param>
         /// <returns>The <see cref="IApplicationBuilder"/> instance this method extends.</returns>
@@ -20,7 +20,7 @@ namespace Microsoft.AspNetCore.Builder
                 throw new ArgumentNullException(nameof(app));
             }
 
-            var marker = app.ApplicationServices.GetService<KafkaConsistenceMarkerService>();
+            var marker = app.ApplicationServices.GetService<ConsistencyMarkerService>();
             if (marker == null) {
                 throw new InvalidOperationException("AddKafkaConsistence must be called on the service collection.");
             }

src/Cap.Consistency/ConsistenceBuilder.cs → src/Cap.Consistency/ConsistencyBuilder.cs

@@ -3,15 +3,17 @@ using System;
 
 namespace Cap.Consistency
 {
-
-    public class ConsistenceBuilder
+    /// <summary>
+    /// Helper functions for configuring consistency services.
+    /// </summary>
+    public class ConsistencyBuilder
     {
         /// <summary>
-        /// Creates a new instance of <see cref="ConsistenceBuilder"/>.
+        /// Creates a new instance of <see cref="ConsistencyBuilder"/>.
         /// </summary>
         /// <param name="message">The <see cref="Type"/> to use for the message.</param>
         /// <param name="service">The <see cref="IServiceCollection"/> to attach to.</param>
-        public ConsistenceBuilder(Type message, IServiceCollection service) {
+        public ConsistencyBuilder(Type message, IServiceCollection service) {
             MessageType = message;
             Services = service;
         }
@@ -33,15 +35,15 @@ namespace Cap.Consistency
         public Type MessageType { get; private set; }
 
         /// <summary>
-        /// Adds a <see cref="IConsistentMessageStore{TMessage}"/> for the <seealso cref="MessageType"/>.
+        /// Adds a <see cref="IConsistencyMessageStore{TMessage}"/> for the <seealso cref="MessageType"/>.
         /// </summary>
         /// <typeparam name="T">The role type held in the store.</typeparam>
-        /// <returns>The current <see cref="ConsistenceBuilder"/> instance.</returns>
-        public virtual ConsistenceBuilder AddMessageStore<T>() where T : class {
-            return AddScoped(typeof(IConsistentMessageStore<>).MakeGenericType(MessageType), typeof(T));
+        /// <returns>The current <see cref="ConsistencyBuilder"/> instance.</returns>
+        public virtual ConsistencyBuilder AddMessageStore<T>() where T : class {
+            return AddScoped(typeof(IConsistencyMessageStore<>).MakeGenericType(MessageType), typeof(T));
         }
 
-        private ConsistenceBuilder AddScoped(Type serviceType, Type concreteType) {
+        private ConsistencyBuilder AddScoped(Type serviceType, Type concreteType) {
             Services.AddScoped(serviceType, concreteType);
             return this;
         }

src/Cap.Consistency/KafkaConsistenceMarkerService.cs → src/Cap.Consistency/ConsistencyMarkerService.cs

 namespace Cap.Consistency
 {
     /// <summary>
-    /// Used to verify KafkaConsistence was called on a ServiceCollection
+    /// Used to verify Consistency service was called on a ServiceCollection
     /// </summary>
-    public class KafkaConsistenceMarkerService { }
+    public class ConsistencyMarkerService { }
 }
\ No newline at end of file

src/Cap.Consistency/ConsistentMessageManager.cs → src/Cap.Consistency/ConsistencyMessageManager.cs

@@ -11,21 +11,21 @@ namespace Cap.Consistency
     /// Provides the APIs for managing message in a persistence store.
     /// </summary>
     /// <typeparam name="TMessage">The type encapsulating a message.</typeparam>
-    public class ConsistentMessageManager<TMessage> : IDisposable where TMessage : class
+    public class ConsistencyMessageManager<TMessage> : IDisposable where TMessage : class
     {
         private bool _disposed;
         private readonly HttpContext _context;
         private CancellationToken CancellationToken => _context?.RequestAborted ?? CancellationToken.None;
 
         /// <summary>
-        /// Constructs a new instance of <see cref="ConsistentMessageManager{TMessage}"/>.
+        /// Constructs a new instance of <see cref="ConsistencyMessageManager{TMessage}"/>.
         /// </summary>
         /// <param name="store">The persistence store the manager will operate over.</param>
         /// <param name="services">The <see cref="IServiceProvider"/> used to resolve services.</param>
         /// <param name="logger">The logger used to log messages, warnings and errors.</param>
-        public ConsistentMessageManager(IConsistentMessageStore<TMessage> store,
+        public ConsistencyMessageManager(IConsistencyMessageStore<TMessage> store,
             IServiceProvider services,
-            ILogger<ConsistentMessageManager<TMessage>> logger) {
+            ILogger<ConsistencyMessageManager<TMessage>> logger) {
             if (store == null) {
                 throw new ArgumentNullException(nameof(store));
             }
@@ -42,7 +42,7 @@ namespace Cap.Consistency
         ///  Gets or sets the persistence store the manager operates over.
         /// </summary>
         /// <value>The persistence store the manager operates over.</value>
-        protected internal IConsistentMessageStore<TMessage> Store { get; set; }
+        protected internal IConsistencyMessageStore<TMessage> Store { get; set; }
 
         /// <summary>
         /// Gets the <see cref="ILogger"/> used to log messages from the manager.

src/Cap.Consistency/IConsistentMessageStore.cs → src/Cap.Consistency/IConsistencyMessageStore.cs

@@ -5,10 +5,10 @@ using System.Threading.Tasks;
 namespace Cap.Consistency
 {
     /// <summary>
-    /// Provides an abstraction for a store which manages kafka consistent message.
+    /// Provides an abstraction for a store which manages consistent message.
     /// </summary>
     /// <typeparam name="TMessage"></typeparam>
-    public interface IConsistentMessageStore<TMessage> : IDisposable where TMessage : class
+    public interface IConsistencyMessageStore<TMessage> : IDisposable where TMessage : class
     {
         /// <summary>
         /// Finds and returns a message, if any, who has the specified <paramref name="messageId"/>.

src/Cap.Consistency/ServiceCollectionExtensions.cs

@@ -15,12 +15,12 @@ namespace Microsoft.Extensions.DependencyInjection
         /// </summary>
         /// <param name="services">The services available in the application.</param>
         /// <returns>An <see cref="IServiceCollection"/> for application services.</returns>
-        public static ConsistenceBuilder AddKafkaConsistence<TMessage>(this IServiceCollection services)
+        public static ConsistencyBuilder AddKafkaConsistence<TMessage>(this IServiceCollection services)
             where TMessage : class {
 
-            services.TryAddSingleton<KafkaConsistenceMarkerService>();
+            services.TryAddSingleton<ConsistencyMarkerService>();
 
-            return new ConsistenceBuilder(typeof(TMessage), services);
+            return new ConsistencyBuilder(typeof(TMessage), services);
         }
     }
 }
\ No newline at end of file