FastRabbitMQ.Core

nuget url: https://www.nuget.org/packages/Fast.RabbitMQ.Core/

in Startup.cs Startup mothod

 services.AddFastRabbitMQ(a => {
            a.Host = "127.0.0.1";
            a.PassWord = "guest";
            a.UserName = "guest";
            a.Port = 5672;
            a.VirtualHost = "/";
            a.aop = new FastRabbitAop();
    });
    
    or 
    services.AddFastRabbitMQ(new FastRabbitAop());
    RabbitMQ info in db.json
   
   "RabbitMQ": {
     "Host": "127.0.0.1",
     "PassWord": "guest",
     "UserName": "guest",
     "Port": 5672,
     "VirtualHost": "/"
    }
    
     services.AddFastRabbitMQReceive(a => {
        a.QueueName = "test";
        a.IsAutoAsk = false;
        a.Exchange = new FastRabbitMQ.Core.Model.Exchange
        {
             ExchangeName = "test",
             ExchangeType = FastRabbitMQ.Core.Model.ExchangeType.direct,
             RouteKey = "key"
       };
     });
    
    public class FastRabbitAop : IFastRabbitAop
    {
        public void Exception(ExceptionContext context)
        {
            //throw new NotImplementedException();
        }

        public void Receive(ReceiveContext context)
        {
            //throw new NotImplementedException();
        }

        public void Send(SendContext context)
        {
            //throw new NotImplementedException();
        }
        
        public void Delete(DeleteContext context)
        {
            // throw new NotImplementedException();
        }
    }

Test

 var dic = new Dictionary<string, object>();
 dic.Add("1", 1);
            
 var config = new FastRabbitMQ.Model.ConfigModel();
 config.QueueName = "test1";
 config.IsAutoAsk = false;
 config.Exchange = new Exchange
 {
     ExchangeName = "test",
     ExchangeType = ExchangeType.direct,
     RouteKey = "key"
 };
 FastRabbit.Send(config, dic);

FastRabbitMQ

nuget url: https://www.nuget.org/packages/Fast.RabbitMQ/

in Global.asax Application_Start mothod

 FastRabbit.AddMQ(a => {
         a.Host = "127.0.0.1";
         a.PassWord = "guest";
         a.UserName = "guest";
         a.Port = 5672;
         a.VirtualHost = "/";
         a.aop = new FastRabbitAop();
     });

     FastRabbit.AddReceive(a => {
          a.QueueName = "test";
          a.IsAutoAsk = false;
          a.Exchange = new FastRabbitMQ.Model.Exchange
          {
            ExchangeName = "test",
            ExchangeType = FastRabbitMQ.Model.ExchangeType.direct,
            RouteKey = "key"
        };
    });
   
  public class FastRabbitAop : IFastRabbitAop
    {
        public void Exception(ExceptionContext context)
        {
            //throw new NotImplementedException();
        }

        public void Receive(ReceiveContext context)
        {
            //throw new NotImplementedException();
        }

        public void Send(SendContext context)
        {
            //throw new NotImplementedException();
        }
        
        public void Delete(DeleteContext context)
        {
            // throw new NotImplementedException();
        }
    }

Test

 var dic = new Dictionary<string, object>();
 dic.Add("1", 1);            
 var config = new FastRabbitMQ.Model.ConfigModel();
 config.QueueName = "test1";
 config.IsAutoAsk = false;
 config.Exchange = new Exchange
 {
     ExchangeName = "test",
     ExchangeType = ExchangeType.direct,
     RouteKey = "key"
 };
 FastRabbit.Send(config, dic);