RabbitMQ.Client.Easy2Use 0.2.1

RabbitMQ Easy2Use Framework

Features:

• Events
  • Publish using publisher
  • Subscribe using attributes
• Commands
  • Publish commands using publisher
  • Consume commands using attributes
• Logging
  • Default logging in console
  • Use your logging factory to use your own logger

Setup:

The framework is initialized using an extentionMethod on IServiceCollection

// in startup.cs
var options = new BusOptions("DemoExchange"); // exhange name is required

services.InitializeRabbitMQ(options);

BusOptions:

var options = new BusOptions("DemoExchange", // exhange name is required
    hostName: "localhost", // the other parameters are optional
    port: 5672,
    userName: "guest",
    password: "guest");

Dependency injection & Logging

var serviceProvider = services.BuildServiceProvider();

ILoggerFactory loggerFactory = new LoggerFactory()
    .AddSerilog(new LoggerConfiguration()
    .MinimumLevel.Information()
    .Enrich.FromLogContext()
    .WriteTo.Console()
    .WriteTo.File(new JsonFormatter(), "RabbitMQFramework_Log.json", LogEventLevel.Warning)
    .CreateLogger());

services.InitializeRabbitMQ(options, serviceProvider, loggerFactory);

Usage:

Publish events:

var publisher = new EventPublisher(options); // use the same busoptions as during initialize (advised is to use DI for this)
publisher.Publish(new ExampleEvent("Example.Demo.ExampleEvent") { Name = "Voorbeeld", Test = 1155 });

Subscribe to events:

[Topic("Example.#.ExampleEvent2")] // the exhange will filter the events with the given topics
[Topic("Example.Demo.*")]
[EventListener("ExampleQueue")] // use this attribute to make the framework recognize this class as a Listener (it requires the queuename)
 public class ExampleListener
 {
     private IExampleInjection _injected;

     public ExampleListener(IExampleInjection exampleInjection) // to use dependency injection, you must pass a buildServiceProvider in the BusOptions during initializing
     {
         _injected = exampleInjection;
     }

     [ExecuteOnEvent] // with this attribute the framework will see this method as a callback method
     public void ExampleEventName(ExampleEvent evt) // events of this type will call this method
     {
         Console.WriteLine($"Wow an event happened and its name was \"{evt.Name}\"");
         _injected.Print();
     }

     [ExecuteOnEvent]
     public void ExampleEventName2(ExampleEvent2 evt)
     {
         Console.WriteLine($"Wow an event happened and its name was \"{evt.Name}\"");
         _injected.Print();
     }
 }

Publish commands:

CommandPublisher commander = new CommandPublisher(options); // use the same busoptions as during initialize (advised is to use DI for this)
string result = commander.Call(new ExampleCommand()); // the result will be in JSON format

Consume commands:

[CommandConsumer] // use this attribute to make the framework recognize this class as a Consumer
public class ExampleConsumer
{
    public object ExampleCommandReceived(ExampleCommand command)
    {
        Console.WriteLine("I will do some things becouse I got a command");
        Thread.Sleep(1000);
        Console.WriteLine("Consumer is done!");
        return new { text = "can you read this?" };
    }
}