acken

private Func<string, bool> _itemHandler;
		private IConnection _connection;
		private IModel _channel;
		private QueueingBasicConsumer _consumer;
		private bool _stop = false;
		
		public Dequeuer(Func<string, bool> itemHandler)
		{
			_itemHandler = itemHandler;
		}

acken

using System;
using RabbitMQ.Client;
using RabbitMQ.Client.MessagePatterns;
using RabbitMQ.Client.Framing.v0_9;
using System.Threading;
using System.Text;
namespace SladrehankEnqueuer.Core
{
	public class Enqueuer
	{

acken

        private void setInitialUsedSpace()
        {
            _sizeCalculator.Calculate().ToList()
                .ForEach(calculation => DecreaseUsedSpaceForVolume(calculation.Key).With(calculation.Value));
            _volumes.ForEach(x => logInitialSize(x));
        }

        private void handle(UploadFinishedMessage message)
        {
            var task = message.Task;