RedisTransport

var queueName = "example";
var connectionString = "192.168.0.212";
var queueConnection = new QueueConnection(queueName, connectionString);
using (var queueContainer = new QueueContainer<RedisQueueInit>())
{
	using (var queue = queueContainer.CreateProducer<SimpleMessage>(queueConnection))
	{
		queue.Send(new SimpleMessage{Message = "hello world"});
	}
}

var queueConnection = new QueueConnection(queueName, connectionString);
using (var queueContainer = new QueueContainer<RedisQueueInit>())
{
	using (var queue = queueContainer.CreateConsumer(queueConnection))
    {
		var notifications = new ConsumerQueueNotifications(
			(n) => Console.WriteLine($"Error: {n.Error}"),
			(n) => Console.WriteLine($"Receive error: {n.Error}"),
			(n) => Console.WriteLine($"Moved to error queue: {n.MessageId}"),
			(n) => Console.WriteLine($"Poison message: {n.MessageId}"),
			(n) => Console.WriteLine($"Rollback: {n.MessageId}"),
			(n) => Console.WriteLine($"Completed: {n.MessageId}"));
		queue.Start<SimpleMessage>(HandleMessages, notifications);
        Console.WriteLine("Processing messages - press any key to stop");
        Console.ReadKey((true));
    }
}

private void HandleMessages(IReceivedMessage<SimpleMessage> message, IWorkerNotification notifications)
{
    notifications.Log.LogDebug($"Processing Message {message.Body.Message}");
}