Startup.cs

public class Startup
{
    public void Configure(IApplicationBuilder app, IHostingEnvironment env)
    {
        if (env.IsDevelopment())
        {
            app.UseDeveloperExceptionPage();
        }

        app.UseMvc();
    }

    public void ConfigureServices(IServiceCollection services)
    {
        services.AddMvc().SetCompatibilityVersion(CompatibilityVersion.Version_2_2);

        services.AddMassTransit(cfg =>
        {
            cfg.AddConsumer<ValueConsumer>();

            cfg.AddBus(provider => Bus.Factory.CreateUsingInMemory(x =>
            {
                x.UseExtensionsLogging(provider.GetService<ILoggerFactory>());

                x.ReceiveEndpoint("value", e =>
                {
                    e.ConfigureConsumer<ValueConsumer>(provider);

                    EndpointConvention.Map<AddValue>(e.InputAddress);
                });
            }));

            cfg.AddRequestClient<AddValue>();
        });

        services.AddSingleton<IHostedService, BusService>();
    }
}