Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- using System;
- namespace PublisherConsumer
- {
- class Program
- {
- static void Main(string[] args)
- {
- RMQ rmq = new RMQ();
- Console.WriteLine("Tekan tombol apapun untuk inisialisasi RMQ parameters.");
- Console.ReadKey();
- rmq.InitRMQConnection(); // inisialisasi parameter (secara default) untuk koneksi ke server RMQConsole.WriteLine("Tekan tombol apapun untuk membuka koneksi ke RMQ.");Console.ReadKey();
- rmq.CreateRMQConnection(); // memulai koneksi dengan RMQ
- Console.Write("Masukkan nama queue channel untuk mengirim pesan melalui RMQ.\n>> ");
- string queue_name = Console.ReadLine();
- rmq.CreateRMQChannel(queue_name);
- Console.Write("Masukkan pesan yang akan dikirim atau 'exit' to close.\n>>");
- Console.Write(">> tujuan: ");
- string tujuan = Console.ReadLine();
- Console.Write(">> pesan: ");
- string inputMsg = Console.ReadLine();
- while (inputMsg != "exit")
- {
- rmq.SendMessage(tujuan, inputMsg);
- Console.Write(">> tujuan: ");
- tujuan = Console.ReadLine();
- Console.Write(">> pesan: ");
- inputMsg = Console.ReadLine();
- }
- rmq.Disconnect();
- }
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement