using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using Amqp;
using Amqp.Framing;
using Amqp.Types;

namespace test
{
    class ReplyTo
    {
        public static void RunTest(string[] args)
        {
            string broker = args.Length >= 1 ? args[0] : "amqp://localhost:5672";
            string queue = args.Length >= 2 ? args[1] : "jms.queue.test";

            Address address = new Address(broker);
            string replyToQueue = "jms.queue.replyQ";
            string testName = "Replyto";
            const int nMsgs = 1;

            Connection connection = new Connection(address);
            Session session = new Session(connection);

            ////////////////////////////////////////////////////////////////////////////////////////////////////////
            //send messages and close connection and session
            SenderLink sender = new SenderLink(session, "sender-" + testName, queue);

            for(int i = 0; i < nMsgs; i++)
            {
                Message msg = new Message("tests Reply to");
                msg.Properties = new Properties();
                msg.Header = new Header() { Durable = false };
                msg.Properties.ReplyTo = replyToQueue;
                sender.Send(msg);
            }

            sender.Close();
            session.Close();
            connection.Close();
            /////////////////////////////////////////////////////////////////////////////////////////////////////////
            //receive messages and send to reply to queue
            connection = new Connection(address);
            session = new Session(connection);
            ReceiverLink receiver = new ReceiverLink(session, "receiver-" + testName, queue);

            for (int i = 0; i < nMsgs; ++i)
            {
                Message message = receiver.Receive();
                receiver.Accept(message);
                Console.WriteLine("Msg from test queue: Durable={0}", message.Header.Durable);

                //send messages on reply queue
                SenderLink replySender = new SenderLink(session, "replyToSender", message.Properties.ReplyTo);
                replySender.Send(message);
                replySender.Close();
            }

            receiver.Close();
            session.Close();
            connection.Close();
            ////////////////////////////////////////////////////////////////////////////////////////////////////////
            //receive messages from reply queue
            connection = new Connection(address);
            session = new Session(connection);
            receiver = new ReceiverLink(session, "receiver-" + testName, replyToQueue);

            for (int i = 0; i < nMsgs; ++i)
            {
                Message message = receiver.Receive();
                receiver.Accept(message);
                Console.WriteLine("Msg from replyQ queue: Durable={0}", message.Header.Durable);
            }

            receiver.Close();
            session.Close();
            connection.Close();
            ////////////////////////////////////////////////////////////////////////////////////////////////////////
            Console.ReadLine();
        }
    }
}