Infrastructure.RabbitMQ 1.0.0

A Production-Ready RabbitMQ Configuration Built For .Net Core Application

Description

This package provide utility classes that can be used if you want your API or Services to publish / listen to message in a RabbitMQ queue.

Basic Usage

Publish to a Channel / Queue

1.Setup Dependency Injection

services.AddTransient<IMessagePublisher>((svc) =>
    {
        string rabbitMQHost = "your rabbit host";
        string rabbitMQUserName = "rabbit username";
        string rabbitMQPassword = "";

        return new RabbitMQChannelPublisher(rabbitMQHost, rabbitMQUserName, rabbitMQPassword, "channel name");
    });

2. Publish a message

    _messagePublisher.PublishMessageAsync("", object message, "channel name");

For pub / sub pattern, simple replace RabbitMQChannelPublisher with RabbitMQMessagePublisher(rabbitMQHost, rabbitMQUserName, rabbitMQPassword, "queue name")

Listen for message from a Channel / Queue

1.Setup Dependency Injection

services.AddTransient<IChannelHandler>((svc) =>
    {
        string rabbitMQHost = "your rabbit host";
        string rabbitMQUserName = "rabbit username";
        string rabbitMQPassword = "";

        return new RabbitMQChannelHandler(rabbitMQHost, rabbitMQUserName, rabbitMQPassword, "channel name");
    });

2. Implement IChannelHandlerCallBack interface

    public class ReceiverManager : IChannelHandlerCallback
    {
        IChannelHandler _messageHandler;

        public ReceiverManager(IChannelHandler messageHandler)
        {
            _messageHandler = messageHandler;
        }
    }

3. Handling Message

        public async Task<bool> HandleChannelAsync(string message)
        {
            // Do something with the message
            return true;
        }

For pub / sub pattern, simple replace RabbitMQChannelHandler with RabbitMQMessageHandler(rabbitMQHost, rabbitMQUserName, rabbitMQPassword, "queue name"), and IChannelHandlerCallback with IMessageHandlerCallback