4.2. メッセージの受信

namespace SimpleRecv
{
    using System;
    using Amqp;                                                                 

    class SimpleRecv
    {
        static void Main(string[] args)
        {
            string    url = (args.Length > 0) ? args[0] :                       
                "amqp://guest:guest@127.0.0.1:5672";
            string source = (args.Length > 1) ? args[1] : "examples";           
            int     count = (args.Length > 2) ? Convert.ToInt32(args[2]) : 10;  

            Address      peerAddr = new Address(url);                           
            Connection connection = new Connection(peerAddr);                   
            Session       session = new Session(connection);
            ReceiverLink receiver = new ReceiverLink(session, "recv-1", source);

            for (int i = 0; i < count; i++)
            {
                Message msg = receiver.Receive();                               
                receiver.Accept(msg);                                           
                Console.WriteLine("Received: " + msg.Body.ToString());
            }

            receiver.Close();                                                   
            session.Close();
            connection.Close();
        }
    }
}

namespace SimpleRecv
{
    using System;
    using Amqp;                                                                 

    class SimpleRecv
    {
        static void Main(string[] args)
        {
            string    url = (args.Length > 0) ? args[0] :                       

                "amqp://guest:guest@127.0.0.1:5672";
            string source = (args.Length > 1) ? args[1] : "examples";           

            int     count = (args.Length > 2) ? Convert.ToInt32(args[2]) : 10;  

            Address      peerAddr = new Address(url);                           

            Connection connection = new Connection(peerAddr);                   

            Session       session = new Session(connection);
            ReceiverLink receiver = new ReceiverLink(session, "recv-1", source);

            for (int i = 0; i < count; i++)
            {
                Message msg = receiver.Receive();                               

                receiver.Accept(msg);                                           

                Console.WriteLine("Received: " + msg.Body.ToString());
            }

            receiver.Close();                                                   

            session.Close();
            connection.Close();
        }
    }
}