refactor

src/DotNetCore.CAP.MongoDB/CAP.MongoDBCapOptionsExtension.cs

@@ -2,13 +2,13 @@
 // Licensed under the MIT License. See License.txt in the project root for license information.
 
 using System;
-using DotNetCore.CAP;
 using DotNetCore.CAP.Abstractions;
 using DotNetCore.CAP.Processor;
 using Microsoft.Extensions.DependencyInjection;
 
 namespace DotNetCore.CAP.MongoDB
 {
+    // ReSharper disable once InconsistentNaming
     public class MongoDBCapOptionsExtension : ICapOptionsExtension
     {
         private readonly Action<MongoDBOptions> _configure;
@@ -23,10 +23,11 @@ namespace DotNetCore.CAP.MongoDB
             services.AddSingleton<CapDatabaseStorageMarkerService>();
             services.AddSingleton<IStorage, MongoDBStorage>();
             services.AddSingleton<IStorageConnection, MongoDBStorageConnection>();
+
             services.AddScoped<ICapPublisher, CapPublisher>();
             services.AddScoped<ICallbackPublisher, CapPublisher>();
-            services.AddTransient<ICollectProcessor, MongoDBCollectProcessor>();
 
+            services.AddTransient<ICollectProcessor, MongoDBCollectProcessor>();
             services.AddTransient<IMongoTransaction, MongoTransaction>();
 
             var options = new MongoDBOptions();

src/DotNetCore.CAP.MongoDB/CAP.MongoDBOptions.cs

@@ -3,6 +3,7 @@
 
 namespace DotNetCore.CAP.MongoDB
 {
+    // ReSharper disable once InconsistentNaming
     public class MongoDBOptions
     {
         /// <summary>

src/DotNetCore.CAP.MongoDB/MongoDBUtil.cs

@@ -28,6 +28,7 @@ namespace DotNetCore.CAP.MongoDB
             if (session == null)
             {
                 result = await collection.FindOneAndUpdateAsync(filter, updateDef, _options);
+               
             }
             else
             {