Commit 5b3f5c2c authored by Savorboard's avatar Savorboard

Add service inject

parent 556cb5a0
...@@ -22,6 +22,8 @@ namespace DotNetCore.CAP ...@@ -22,6 +22,8 @@ namespace DotNetCore.CAP
public void AddServices(IServiceCollection services) public void AddServices(IServiceCollection services)
{ {
services.AddSingleton<CapStorageMarkerService>(); services.AddSingleton<CapStorageMarkerService>();
services.AddSingleton<IDataStorage, MySqlDataStorage>();
services.AddSingleton<IStorageInitializer, MySqlStorageInitializer>(); services.AddSingleton<IStorageInitializer, MySqlStorageInitializer>();
services.AddTransient<CapTransactionBase, MySqlCapTransaction>(); services.AddTransient<CapTransactionBase, MySqlCapTransaction>();
......
...@@ -4,6 +4,7 @@ ...@@ -4,6 +4,7 @@
using System; using System;
using DotNetCore.CAP.Internal; using DotNetCore.CAP.Internal;
using DotNetCore.CAP.RabbitMQ; using DotNetCore.CAP.RabbitMQ;
using DotNetCore.CAP.Transport;
using Microsoft.Extensions.DependencyInjection; using Microsoft.Extensions.DependencyInjection;
// ReSharper disable once CheckNamespace // ReSharper disable once CheckNamespace
...@@ -23,6 +24,7 @@ namespace DotNetCore.CAP ...@@ -23,6 +24,7 @@ namespace DotNetCore.CAP
services.AddSingleton<CapMessageQueueMakerService>(); services.AddSingleton<CapMessageQueueMakerService>();
services.Configure(_configure); services.Configure(_configure);
services.AddSingleton<ITransport, RabbitMQMessageSender>();
services.AddSingleton<IConsumerClientFactory, RabbitMQConsumerClientFactory>(); services.AddSingleton<IConsumerClientFactory, RabbitMQConsumerClientFactory>();
services.AddSingleton<IConnectionChannelPool, ConnectionChannelPool>(); services.AddSingleton<IConnectionChannelPool, ConnectionChannelPool>();
......
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