Bondx.RabbitMQ.Extentions 1.0.2

RabbitMq Extention

Bondx.RabbitMQ.Extentions is a extention methods, for make communication easy.

• Easy to publish object to queue
• Easy to subscribe them
• Easy to make exchanges, queues and bindings itself

New Features!

• Add PushAndReply to producer. Now you can send message to queue and after consumer subscribe it, it returns message to your queue.
• Fix async consumers problem

You can also:

• Configure Queue to have dlx echange and route, priprity and retries
• push events with custom retry

Installation

Install package from nuget.

$ Install-Package Bondx.RabbitMQ.Extentions -Version 1.0.2

Add injection to startup.cs file if you net to publish events..

$ services.AddProducer(configuration, "mq");

where mq is section name

"mq": {
    "Host": "localhost",
    "Port": 5672,
    "UserName": "guest",
    "Password": "guest",
    "VirtualHost":"/test"
}

Now inject IProducer to the constructor and use it.

example of rise syncronus event:

producer.PushDynamic<T>(msg);
producer.Push<BxMessage>(exchange, routingkey, msg);
...

example of rise asyncronus event:

await producer.PushDynamicAsync<T>(msg);
await producer.PushAsync<BxMessage>(exchange, routingkey, msg);
...

example of register subscriber

var _consumers = ConsumerFactory.Build(ConsumerType.Classic, mqConfiguration, ServiceProvider, logger);
_consumers.Subscribe<BxMessage>((msg, provider) => {
          Console.WriteLine(JsonConvert.SerializeObject(msg));
          return Task.CompletedTask;
});

example of ConfigurationObject, for ConsumerType.Classic

ConsumerConfiguration cf = new ConsumerConfiguration {
                Configuration = new MqConfiguration {
                    Host = "localhost",
                    Port = 5672,
                    UserName = "guest",
                    Password = "guest"
                },
                Queue = new QueueParams {
                    Name = "CUSTOMERS",
                    Routing = ["1.1.1", "1.2.1"],
                    QueueArgs = new QueueArg[] { new QueueArg
                            {
                                Key = QueueArgKey.DeadLetterExchage,
                                Value = "bx.exchange.fanout.dl"
                            },
                            new QueueArg
                            {
                                Key = QueueArgKey.MaxPriority,
                                Value = 5
                            }
                    },
                    "DLXQueue": {
                        "Name": "retry_queue_name.dlx",
                        "Routing": "1.1.1",
                        "Delay": 30000
                      }
                },
                Exchange = new ExchangeParams() {
                    Name = "bx.exchange.direct",
                    Type = ExchangeType.Direct
                },
                ExchangeDLQ = new ExchangeParams() {
                    Name = "bx.exchange.fanout.dl",
                    Type = ExchangeType.Fanout
                }
            };

example of ConfigurationObject, for ConsumerType.Dynamic

ConsumerConfiguration cf = new ConsumerConfiguration {
                Configuration = new MqConfiguration {
                    Host = "localhost",
                    Port = 5672,
                    UserName = "guest",
                    Password = "guest"
                }
            };