class RMQ
    {
        public ConnectionFactory connectionFactory;
        public IConnection connection;
        public IModel channel;

        string varglob;
        string message;
        byte[] body;

        public void InitRMQConnection(string host = "10.0.45.126", int port = 5672, string user = "miftah.rangga20",
        string pass = "123")
        {
            connectionFactory = new ConnectionFactory();
            connectionFactory.HostName = host;
            //connectionFactory.Port = port;
            connectionFactory.UserName = user;
            connectionFactory.Password = pass;
        }
        public void CreateRMQConnection()
        {
            connection = connectionFactory.CreateConnection();
            //Console.WriteLine("Koneksi " + (connection.IsOpen ? "Berhasil!" : "Gagal!"));
        }
        public void CreateRMQChannel(string queue_name, string routingKey = "", string exchange_name =
        "")
        {
            if (connection.IsOpen)
            {
                channel = connection.CreateModel();
                //Console.WriteLine("Channel " + (channel.IsOpen ? "Berhasil!" : "Gagal!"));
            }
            if (channel.IsOpen)
            {
                channel.QueueDeclare(queue: queue_name,
                durable: true,
                exclusive: false,
                autoDelete: false,
                arguments: null);
                //Console.WriteLine("Queue telah dideklarasikan..");
            }
        }
        public void SendMessage(string tujuan, string msg = "send")
        {
            byte[] responseBytes = Encoding.UTF8.GetBytes(msg);// konversi pesan dalam bentuk string menjadi byte
            channel.BasicPublish(exchange: "",
            routingKey: tujuan,
            basicProperties: null,
            body: responseBytes);
            //Console.WriteLine("Pesan: '" + msg + "' telah dikirim.");
        }

        public void WaitingMessage(string queue_name)
        {
            using (channel = connection.CreateModel())
            {
                channel.QueueDeclare(queue: queue_name,
                durable: true,
                exclusive: false,
                autoDelete: false,
                arguments: null);
                var consumer = new EventingBasicConsumer(channel);
                consumer.Received += (model, ea) =>
                {
                    body = ea.Body;
                    message = Encoding.UTF8.GetString(body);
                    //varglob = message;  //message adalah variable global (ga ke-assign)
                    //Console.WriteLine(" [x] Pesan diterima: {0}", message);
                };

                //varglob = Encoding.UTF8.GetString(body);
                channel.BasicConsume(queue: queue_name,
                noAck: true,
                consumer: consumer);
                //Console.WriteLine(" Tekan [enter] untuk memutus koneksi.");
                //Console.ReadLine();
                //Disconnect();
            }
        }

        public string GetMessage()
        {
            return varglob;
        }

        public void Disconnect()
        {
            channel.Close();
            channel = null;
            //Console.WriteLine("Channel ditutup!");
            if (connection.IsOpen)
            {
                connection.Close();
            }
            //Console.WriteLine("Koneksi diputus!");
            connection.Dispose();
            connection = null;
        }
    }