using System;
using System.Collections.Generic;
using System.Threading;
using Amqp.Framing;
using Amqp.Extensions;
using Amqp.Sasl;
using Amqp.Types;

namespace Amqp.Extensions.Examples
{
    class Program
    {
        static void Main(string[] args)
        {
            // create receiver link on broker0
            Connection connection0 = new Connection(new Address("amqp://localhost:5672"));       
            Session session0 = new Session(connection0);
            ReceiverLink receiver0 = new ReceiverLink(session0, "test", "orders");
            
            // send messages to broker0
            SenderLink sender = new SenderLink(session0, "sender", "orders");
            Message message = new Message("a message!");
            
            for (var i = 0; i < 5; i++)
            {
                sender.Send(message);
                Thread.Sleep(100);
            }

            // receive 1 of 5, works as expected...
            Message m = receiver0.Receive(TimeSpan.FromSeconds(1));
            Console.WriteLine(m.Body);
            receiver0.Accept(m);
            session0.Close();
            connection0.Close();

            // create receiver link on broker1
            Connection connection1 = new Connection(new Address("amqp://localhost:5673"));       
            Session session1 = new Session(connection1);
            ReceiverLink receiver1 = new ReceiverLink(session1, "test", "orders");

            // these 4 messages are removed from broker0 (ack'd) but never delivered. NPE seen in logs on broker1
            for (var i = 0; i < 4; i++)
            {   
                m = receiver1.Receive(TimeSpan.FromSeconds(1));
                if (m != null)
                {
                    Console.WriteLine(m.Body);
                    receiver1.Accept(m);
                }
            }

            sender.Close();
            session1.Close();
            connection1.Close();
        }
    }
}