Dev

README.md

@@ -1,5 +1,6 @@
 # RabbitMQ.EventBus.AspNetCore 　　　　　　　　　　[Wiki](https://github.com/ojdev/RabbitMQ.EventBus.AspNetCore/wiki)
-[![DNC](https://img.shields.io/badge/.netcore-%3E%3D2.0-green.svg)](#)
+[![DNC](https://img.shields.io/badge/.netcore-%3E%3D2.1-green.svg)](#)
+[![CodeFactor](https://www.codefactor.io/repository/github/ojdev/rabbitmq.eventbus.aspnetcore/badge)](https://www.codefactor.io/repository/github/ojdev/rabbitmq.eventbus.aspnetcore)
 [![AppVeyor](https://img.shields.io/appveyor/ci/ojdev/rabbitmq-eventbus-aspnetcore.svg?style=popout)](https://ci.appveyor.com/project/ojdev/rabbitmq-eventbus-aspnetcore)
 [![NuGet](https://img.shields.io/nuget/v/RabbitMQ.EventBus.AspNetCore.svg?style=popout)](https://www.nuget.org/packages/RabbitMQ.EventBus.AspNetCore)
 [![NuGet](https://img.shields.io/nuget/dt/RabbitMQ.EventBus.AspNetCore.svg?style=popout)](https://www.nuget.org/packages/RabbitMQ.EventBus.AspNetCore)

RabbitMQ.EventBus.AspNetCore.Simple/Controllers/MessageBody.cs

@@ -0,0 +1,13 @@
+using RabbitMQ.EventBus.AspNetCore.Attributes;
+using RabbitMQ.EventBus.AspNetCore.Events;
+using System;
+
+namespace RabbitMQ.EventBus.AspNetCore.Simple.Controllers
+{
+    [EventBus(Exchange = "RabbitMQ.EventBus.Simple", RoutingKey = "rabbitmq.eventbus.test")]
+    public class MessageBody : IEvent
+    {
+        public string Body { get; set; }
+        public DateTimeOffset Time { get; set; }
+    }
+}

RabbitMQ.EventBus.AspNetCore.Simple/Controllers/MessageBody1.cs

@@ -0,0 +1,14 @@
+using RabbitMQ.EventBus.AspNetCore.Attributes;
+using RabbitMQ.EventBus.AspNetCore.Events;
+using System;
+
+namespace RabbitMQ.EventBus.AspNetCore.Simple.Controllers
+{
+    //[EventBus(Exchange = "RabbitMQ.EventBus.Simple", RoutingKey = "rabbitmq.eventbus.test")]
+    [EventBus(Exchange = "RabbitMQ.EventBus.Simple", RoutingKey = "rabbitmq.eventbus.test1")]
+    public class MessageBody1 : IEvent
+    {
+        public string Body { get; set; }
+        public DateTimeOffset Time { get; set; }
+    }
+}

RabbitMQ.EventBus.AspNetCore.Simple/Controllers/MessageBodyHandle.cs

@@ -0,0 +1,34 @@
+using Microsoft.Extensions.Logging;
+using RabbitMQ.EventBus.AspNetCore.Events;
+using System;
+using System.Threading.Tasks;
+
+namespace RabbitMQ.EventBus.AspNetCore.Simple.Controllers
+{
+    public class MessageBodyHandle : IEventHandler<MessageBody1>, IDisposable
+    {
+        private Guid id;
+        private readonly ILogger<MessageBodyHandle> _logger;
+
+        public MessageBodyHandle(ILogger<MessageBodyHandle> logger)
+        {
+            id = Guid.NewGuid();
+            _logger = logger ?? throw new ArgumentNullException(nameof(logger));
+        }
+        public void Dispose()
+        {
+            Console.WriteLine("释放");
+        }
+
+        public Task Handle(MessageBody1 message, EventHandlerArgs args)
+        {
+            Console.WriteLine("==================================================");
+            Console.WriteLine(id + "=>" + typeof(MessageBody1).Name);
+            Console.WriteLine(message.Serialize());
+            Console.WriteLine(args.Original);
+            Console.WriteLine(args.Redelivered);
+            Console.WriteLine("==================================================");
+            return Task.CompletedTask;
+        }
+    }
+}

RabbitMQ.EventBus.AspNetCore.Simple/Controllers/ValuesController.cs

@@ -1,52 +1,8 @@
 using Microsoft.AspNetCore.Mvc;
-using Microsoft.Extensions.Logging;
-using RabbitMQ.EventBus.AspNetCore.Attributes;
-using RabbitMQ.EventBus.AspNetCore.Events;
 using System;
-using System.Threading.Tasks;
 
 namespace RabbitMQ.EventBus.AspNetCore.Simple.Controllers
 {
-    [EventBus(Exchange = "RabbitMQ.EventBus.Simple", RoutingKey = "rabbitmq.eventbus.test")]
-    public class MessageBody : IEvent
-    {
-        public string Body { get; set; }
-        public DateTimeOffset Time { get; set; }
-    }
-    //[EventBus(Exchange = "RabbitMQ.EventBus.Simple", RoutingKey = "rabbitmq.eventbus.test")]
-    [EventBus(Exchange = "RabbitMQ.EventBus.Simple", RoutingKey = "rabbitmq.eventbus.test1")]
-    public class MessageBody1 : IEvent
-    {
-        public string Body { get; set; }
-        public DateTimeOffset Time { get; set; }
-    }
-    public class MessageBodyHandle : IEventHandler<MessageBody1>, IDisposable
-    {
-        private Guid id;
-        private readonly ILogger<MessageBodyHandle> _logger;
-
-        public MessageBodyHandle(ILogger<MessageBodyHandle> logger)
-        {
-            id = Guid.NewGuid();
-            _logger = logger ?? throw new ArgumentNullException(nameof(logger));
-        }
-        public void Dispose()
-        {
-            Console.WriteLine("释放");
-        }
-
-
-        public Task Handle(MessageBody1 message, EventHandlerArgs args)
-        {
-            Console.WriteLine("==================================================");
-            Console.WriteLine(id + "=>" + typeof(MessageBody1).Name);
-            Console.WriteLine(message.Serialize());
-            Console.WriteLine(args.Original);
-            Console.WriteLine(args.Redelivered);
-            Console.WriteLine("==================================================");
-            return Task.CompletedTask;
-        }
-    }
     [Route("api/[controller]")]
     [ApiController]
     public class ValuesController : ControllerBase

src/RabbitMQ.EventBus.AspNetCore/Events/IEvent.cs

@@ -7,6 +7,5 @@ namespace RabbitMQ.EventBus.AspNetCore.Events
     /// </summary>
     public interface IEvent
     {
-
     }
-}
+}

src/RabbitMQ.EventBus.AspNetCore/Factories/DefaultRabbitMQPersistentConnection.cs

@@ -11,7 +11,6 @@
 
 namespace RabbitMQ.EventBus.AspNetCore.Factories
 {
-
     internal sealed class DefaultRabbitMQPersistentConnection : IRabbitMQPersistentConnection
     {
         public RabbitMQEventBusConnectionConfiguration Configuration { get; }
@@ -21,7 +20,6 @@ internal sealed class DefaultRabbitMQPersistentConnection : IRabbitMQPersistentC
         private bool _disposed;
         private readonly object sync_root = new object();
 
-
         public string Endpoint => _connection?.Endpoint.ToString();
         public DefaultRabbitMQPersistentConnection(RabbitMQEventBusConnectionConfiguration configuration, IConnectionFactory connectionFactory, ILogger<DefaultRabbitMQPersistentConnection> logger)
         {
@@ -32,18 +30,15 @@ public DefaultRabbitMQPersistentConnection(RabbitMQEventBusConnectionConfigurati
 
         public bool IsConnected => _connection != null && _connection.IsOpen && !_disposed;
 
-
         public IModel CreateModel()
         {
             if (!IsConnected)
             {
                 throw new InvalidOperationException("No RabbitMQ connections are available to perform this action");
             }
-
             return _connection.CreateModel();
         }
 
-
         public void Dispose()
         {
             if (_disposed)
@@ -61,7 +56,6 @@ public void Dispose()
             }
         }
 
-
         public bool TryConnect()
         {
             _logger.WriteLog(Configuration.Level, "RabbitMQ Client is trying to connect");
@@ -96,6 +90,7 @@ public bool TryConnect()
                 }
             }
         }
+
         private void OnConnectionBlocked(object sender, ConnectionBlockedEventArgs e)
         {
             if (_disposed)

src/RabbitMQ.EventBus.AspNetCore/Factories/IRabbitMQPersistentConnection.cs

@@ -31,6 +31,5 @@ public interface IRabbitMQPersistentConnection : IDisposable
         /// </summary>
         /// <returns></returns>
         IModel CreateModel();
-
     }
-}
+}