a wrapper project on RabbitMQ.Client for some common usecases
- Create and get a Connection
- Create different types of Exchanges and bind them to queues with route-key
- Send messages to queues
- Get messages numbers of each queue
- Get Top(n) messgaes on queues
- etc
- Install the nuget package
Install-Package MicroLib.RabbitMQ.Client.Helper.Standard
class Program
{
static RabbitMqFunctions _rabbitMQFunctions;
static void Main(string[] args)
{
_rabbitMQFunctions = new RabbitMqFunctions();
// Init connection to rabbitMQ
var _connection = _rabbitMQFunctions.CreateConnection(
new ConnectionInputModel
{
ClientName="ConsoleSampleApp1000",
ServerIP = "localhost",
ServerPort = 15672,
Username = "guest",
Password = "guest"
});
...
...
...