using MassTransit;
using MassTransit.TestFramework;
using MassTransit.Testing.Observers;
using NUnit.Framework;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace Test.Messaging
{
    [TestFixture]
    public class ConsumerTests : InMemoryTestFixture
    {
        private TestConsumeMessageObserver<PlaceOrderMessage> _observer;

        [OneTimeSetUp]
        public async Task Before()
        {
            _observer = GetConsumeObserver<PlaceOrderMessage>();
            Bus.ConnectConsumeMessageObserver(_observer);

            await Bus.Publish(new SampleMessage() { CorrelationId = Guid.NewGuid(), SubmitDate = DateTime.Now, OrderNumber = 1000 });
        }

        [Test]
        public async Task Consume_Should_Receive_And_ProcessPublishedMessage()
        {
            var expectedOrderNumber = 1000;
            var orderMessage = await _observer.PostConsumed;

            Assert.AreEqual(expectedOrderNumber, orderMessage.OrderNumber);
        }
    }
}