Request/Reply Masstransit + RabbitMq

using System;
using MassTransit;

namespace TestMasstransitRabbitMqReqReply
{
    internal class Program
    {
        private static void Main(string[] args)
        {
            string url = @"rabbitmq://localhost/test";
            IServiceBus requestorBus = ServiceBusFactory.New(sbc =>
                {
                    sbc.UseRabbitMqRouting();
                    sbc.ReceiveFrom(url + "_requestor");
                    sbc.Validate();
                });

            IServiceBus replierBus = ServiceBusFactory.New(sbc =>
                {
                    sbc.UseRabbitMqRouting();
                    sbc.ReceiveFrom(url + "_replier");
                    sbc.Subscribe(
                        sbs => { sbs.Handler<IConsumeContext<Request>>(ctx => ctx.Respond(new Response {Text = "Hello, " + ctx.Message.Text})); });
                    sbc.Validate();
                });

            Console.WriteLine("Initialization is complete");
            requestorBus.PublishRequest(new Request {Text = "John"},
                                        configurator => configurator.Handle<Response>(message => Console.WriteLine(message.Text)));

            Console.ReadLine();

            requestorBus.Dispose();
            replierBus.Dispose();
        }
    }

    public class Request
    {
        public string Text { get; set; }
    }

    public class Response
    {
        public string Text { get; set; }
    }
}