Advertisement
Guest User

Untitled

a guest
Jul 19th, 2019
92
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 1.39 KB | None | 0 0
  1. public class EftProducerHelper
  2. {
  3. public static void SendMoney(SendingEftModel model)
  4. {
  5. //RabbitMQ bağlantısı için
  6. var factory = new ConnectionFactory() { HostName = "localhost", UserName = "admin", Password = "123456" };
  7. //Channel yaratmak için
  8. using (IConnection connection = factory.CreateConnection())
  9. using (IModel channel = connection.CreateModel())
  10. {
  11. //Kuyruk oluşturma
  12. channel.QueueDeclare(queue: "Eft",
  13. durable: false, //Data fiziksel olarak mı yoksa memoryde mi tutulsun
  14. exclusive: false, //Başka connectionlarda bu kuyruğa ulaşabilsin mi
  15. autoDelete: false, //Eğer kuyruktaki son mesaj ulaştığında kuyruğun silinmesini istiyorsak kullanılır.
  16. arguments: null);//Exchangelere verilecek olan parametreler tanımlamak için kullanılır.
  17.  
  18. string message = JsonConvert.SerializeObject(model);
  19. var body = Encoding.UTF8.GetBytes(message);
  20.  
  21. //Queue ya atmak için kullanılır.
  22. channel.BasicPublish(exchange: "",//mesajın alınıp bir veya birden fazla queue ya konmasını sağlıyor.
  23. routingKey: "Eft", //Hangi queue ya atanacak.
  24. body: body);//Mesajun içeriği
  25. }
  26. }
  27. }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement