Commit b9c31c82 authored by Savorboard's avatar Savorboard

inject failed message processor.

parent 8e41e0d5
...@@ -46,12 +46,13 @@ namespace Microsoft.Extensions.DependencyInjection ...@@ -46,12 +46,13 @@ namespace Microsoft.Extensions.DependencyInjection
//Processors //Processors
services.AddTransient<PublishQueuer>(); services.AddTransient<PublishQueuer>();
services.AddTransient<SubscribeQueuer>(); services.AddTransient<SubscribeQueuer>();
services.AddTransient<FailedJobProcessor>(); services.AddTransient<FailedProcessor>();
services.AddTransient<IDispatcher, DefaultDispatcher>(); services.AddTransient<IDispatcher, DefaultDispatcher>();
//Executors //Executors
services.AddSingleton<IQueueExecutorFactory, QueueExecutorFactory>(); services.AddSingleton<IQueueExecutorFactory, QueueExecutorFactory>();
services.AddSingleton<IQueueExecutor, SubscribeQueueExecutor>(); services.AddSingleton<IQueueExecutor, SubscribeQueueExecutor>();
services.TryAddSingleton<ISubscriberExecutor, DefaultSubscriberExecutor>();
//Options and extension service //Options and extension service
var options = new CapOptions(); var options = new CapOptions();
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment