mookid8000
commented
4 years ago The thing is, Rebus does NOT use IoC for any of its things at runtime.
It uses Injectionist to compose itself from the configuration you choose, which allows you to hook into it in various ways by decorating services, and then it may use IoC to create your handlers if you provided some kind of container adapter.
But the pipelines are constructed by Injectionist when the bus instance is created, and so it is not possible to resolve the steps from your container.
However, it's certainly possible to write a pipeline step that resolves stuff from your container. If you're using Rebus.ServiceProvider, the current scope will be added to the context when your handler(s) have been resolved, so if you add a step like this:
Configure.With(...)
.(...)
.Options(o => {
// (*)
o.Decorate<IPipeline>(c => {
var pipeline = c.Get<IPipeline>();
var step = new MyStep();
return new PipelineStepInjector(pipeline)
.OnReceive(step, PipelineRelativePosition.After, typeof(ActivateHandlersStep));
});
})
.Start();
(positioning your step af Rebus' own ActivateHandlersStep), then your step can get access to the scope like this:
public class MyStep : IIncomingStep
{
public async Task Process(IncomingStepContext context, Func<Task> next)
{
var scope = context.Load<IServiceScope>();
// whee!
await next();
}
}(*) Please always hide the nasty .Decorate(...) stuff behind an extension method so it becomes pretty like this:
Configure.With(...)
.(...)
.Options(o => o.UseMyStep())
.Start();EDIT: Just corrected the first snippet to use ActivateHandlersStep for positioning. Check out this test for a working sample.
slimjack
sabbadino
Hi, I read this wiki page describing how to inject a custom step in the incoming / outgoing pipeline https://github.com/rebus-org/Rebus/wiki/Extensibility
It's no clear to me how to use ioc in this situation : the example provided requires to give a instance of my custom step , while i would like to provide an interface that is resolved by the ioc at run time.
Is it possible ? can you provide an example ? thank you p.s. : using Rebus on dotnertcore 2.2