Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- public class EftProducerHelper
- {
- public static void SendMoney(SendingEftModel model)
- {
- //RabbitMQ bağlantısı için
- var factory = new ConnectionFactory() { HostName = "localhost", UserName = "admin", Password = "123456" };
- //Channel yaratmak için
- using (IConnection connection = factory.CreateConnection())
- using (IModel channel = connection.CreateModel())
- {
- //Kuyruk oluşturma
- channel.QueueDeclare(queue: "Eft",
- durable: false, //Data fiziksel olarak mı yoksa memoryde mi tutulsun
- exclusive: false, //Başka connectionlarda bu kuyruğa ulaşabilsin mi
- autoDelete: false, //Eğer kuyruktaki son mesaj ulaştığında kuyruğun silinmesini istiyorsak kullanılır.
- arguments: null);//Exchangelere verilecek olan parametreler tanımlamak için kullanılır.
- string message = JsonConvert.SerializeObject(model);
- var body = Encoding.UTF8.GetBytes(message);
- //Queue ya atmak için kullanılır.
- channel.BasicPublish(exchange: "",//mesajın alınıp bir veya birden fazla queue ya konmasını sağlıyor.
- routingKey: "Eft", //Hangi queue ya atanacak.
- body: body);//Mesajun içeriği
- }
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement