var busControl = Bus.Factory.CreateUsingRabbitMq(); var source = new CancellationTokenSource(TimeSpan.FromSeconds(10)); await busControl.StartAsync(source.Token); await busControl.Publish<SubmitOrderV2>(new { ExtraData = value });