Test IModel in RabbitMQ.Client

Test.cs

[TestFixture]
public class RabbitMQTest
{
    [Test]
    public void CanMockMQ()
    {
        // Arrange
        var channelMock = new Mock<IModel>();
        channelMock
            .Setup(m => m.BasicConsume(It.IsAny<string>(), It.IsAny<bool>(), It.IsAny<IDictionary>(), It.IsAny<IBasicConsumer>()))
            .Callback<string, bool, object, IBasicConsumer>((queue, noAck, props, consumer) => consumer.HandleBasicDeliver("", 1, false, "exchange", "route", null, new byte[0]));
        var server = new MQUser(channelMock.Object);

        // Act
        server.Abort();
        server.DoStuff();

        // Assert
        channelMock.Verify(m => m.BasicAck(1, false));
    }
}

TestSubject.cs

public class MQUser
{
    readonly IModel channel;

    public MQUser(IModel channel)
    {
        this.channel = channel;
    }

    public void DoStuff()
    {
        var queueName = channel.QueueDeclare();
        var subscription = new Subscription(channel, queueName);
        do
        {
            var msg = subscription.Next();
            // Do stuff with the message
            subscription.Ack(msg);
        } while (!aborted);
    }

    bool aborted;
    public void Abort()
    {
        aborted = true;
    }
}