Advertisement
vitareinforce

contoh struktur program rmq

Sep 8th, 2022
73
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 1.35 KB | None | 0 0
  1. using System;
  2.  
  3. namespace PublisherConsumer
  4. {
  5. class Program
  6. {
  7. static void Main(string[] args)
  8. {
  9. RMQ rmq = new RMQ();
  10. Console.WriteLine("Tekan tombol apapun untuk inisialisasi RMQ parameters.");
  11. Console.ReadKey();
  12. rmq.InitRMQConnection(); // inisialisasi parameter (secara default) untuk koneksi ke server RMQConsole.WriteLine("Tekan tombol apapun untuk membuka koneksi ke RMQ.");Console.ReadKey();
  13. rmq.CreateRMQConnection(); // memulai koneksi dengan RMQ
  14. Console.Write("Masukkan nama queue channel untuk mengirim pesan melalui RMQ.\n>> ");
  15. string queue_name = Console.ReadLine();
  16. rmq.CreateRMQChannel(queue_name);
  17. Console.Write("Masukkan pesan yang akan dikirim atau 'exit' to close.\n>>");
  18. Console.Write(">> tujuan: ");
  19. string tujuan = Console.ReadLine();
  20. Console.Write(">> pesan: ");
  21. string inputMsg = Console.ReadLine();
  22. while (inputMsg != "exit")
  23. {
  24. rmq.SendMessage(tujuan, inputMsg);
  25. Console.Write(">> tujuan: ");
  26. tujuan = Console.ReadLine();
  27. Console.Write(">> pesan: ");
  28. inputMsg = Console.ReadLine();
  29. }
  30. rmq.Disconnect();
  31. }
  32. }
  33. }
  34.  
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement