diff --git a/src/DotNetCore.CAP.EntityFrameworkCore/CAP.SqlServerCapOptionsExtension.cs b/src/DotNetCore.CAP.EntityFrameworkCore/CAP.SqlServerCapOptionsExtension.cs index fe3d97b..0425b8f 100644 --- a/src/DotNetCore.CAP.EntityFrameworkCore/CAP.SqlServerCapOptionsExtension.cs +++ b/src/DotNetCore.CAP.EntityFrameworkCore/CAP.SqlServerCapOptionsExtension.cs @@ -1,6 +1,6 @@ using System; -using DotNetCore.CAP.EntityFrameworkCore; using DotNetCore.CAP.Processor; +using DotNetCore.CAP.SqlServer; using Microsoft.EntityFrameworkCore; using Microsoft.Extensions.DependencyInjection; diff --git a/src/DotNetCore.CAP.EntityFrameworkCore/CapPublisher.cs b/src/DotNetCore.CAP.EntityFrameworkCore/CapPublisher.cs index e90bdad..3cba0a0 100644 --- a/src/DotNetCore.CAP.EntityFrameworkCore/CapPublisher.cs +++ b/src/DotNetCore.CAP.EntityFrameworkCore/CapPublisher.cs @@ -8,7 +8,7 @@ using DotNetCore.CAP.Processor; using Microsoft.EntityFrameworkCore; using Microsoft.EntityFrameworkCore.Storage; -namespace DotNetCore.CAP.EntityFrameworkCore +namespace DotNetCore.CAP.SqlServer { public class CapPublisher : ICapPublisher { diff --git a/src/DotNetCore.CAP.EntityFrameworkCore/DotNetCore.CAP.EntityFrameworkCore.csproj b/src/DotNetCore.CAP.EntityFrameworkCore/DotNetCore.CAP.SqlServer.csproj similarity index 64% rename from src/DotNetCore.CAP.EntityFrameworkCore/DotNetCore.CAP.EntityFrameworkCore.csproj rename to src/DotNetCore.CAP.EntityFrameworkCore/DotNetCore.CAP.SqlServer.csproj index d532199..c2b12cb 100644 --- a/src/DotNetCore.CAP.EntityFrameworkCore/DotNetCore.CAP.EntityFrameworkCore.csproj +++ b/src/DotNetCore.CAP.EntityFrameworkCore/DotNetCore.CAP.SqlServer.csproj @@ -4,8 +4,8 @@ netstandard1.6 - DotNetCore.CAP.EntityFrameworkCore - DotNetCore.CAP.EntityFrameworkCore + DotNetCore.CAP.SqlServer + DotNetCore.CAP.SqlServer 1.6.1 $(PackageTargetFallback);dnxcore50 false @@ -16,12 +16,7 @@ - - - - - - + diff --git a/src/DotNetCore.CAP.EntityFrameworkCore/FetchedMessage.cs b/src/DotNetCore.CAP.EntityFrameworkCore/FetchedMessage.cs index 13dbc0f..521fdeb 100644 --- a/src/DotNetCore.CAP.EntityFrameworkCore/FetchedMessage.cs +++ b/src/DotNetCore.CAP.EntityFrameworkCore/FetchedMessage.cs @@ -1,6 +1,6 @@ using DotNetCore.CAP.Models; -namespace DotNetCore.CAP.EntityFrameworkCore +namespace DotNetCore.CAP.SqlServer { public class FetchedMessage { diff --git a/src/DotNetCore.CAP.EntityFrameworkCore/IAdditionalProcessor.Default.cs b/src/DotNetCore.CAP.EntityFrameworkCore/IAdditionalProcessor.Default.cs index 89126ac..65490ab 100644 --- a/src/DotNetCore.CAP.EntityFrameworkCore/IAdditionalProcessor.Default.cs +++ b/src/DotNetCore.CAP.EntityFrameworkCore/IAdditionalProcessor.Default.cs @@ -5,7 +5,7 @@ using Dapper; using DotNetCore.CAP.Processor; using Microsoft.Extensions.Logging; -namespace DotNetCore.CAP.EntityFrameworkCore +namespace DotNetCore.CAP.SqlServer { public class DefaultAdditionalProcessor : IAdditionalProcessor { diff --git a/src/DotNetCore.CAP.EntityFrameworkCore/SqlServerFetchedMessage.cs b/src/DotNetCore.CAP.EntityFrameworkCore/SqlServerFetchedMessage.cs index 6e9d8e2..06bc461 100644 --- a/src/DotNetCore.CAP.EntityFrameworkCore/SqlServerFetchedMessage.cs +++ b/src/DotNetCore.CAP.EntityFrameworkCore/SqlServerFetchedMessage.cs @@ -4,7 +4,7 @@ using System.Threading; using Dapper; using DotNetCore.CAP.Models; -namespace DotNetCore.CAP.EntityFrameworkCore +namespace DotNetCore.CAP.SqlServer { public class SqlServerFetchedMessage : IFetchedMessage { diff --git a/src/DotNetCore.CAP.EntityFrameworkCore/SqlServerStorage.cs b/src/DotNetCore.CAP.EntityFrameworkCore/SqlServerStorage.cs index 765d88f..57d7e5d 100644 --- a/src/DotNetCore.CAP.EntityFrameworkCore/SqlServerStorage.cs +++ b/src/DotNetCore.CAP.EntityFrameworkCore/SqlServerStorage.cs @@ -1,4 +1,3 @@ -using System; using System.Data.SqlClient; using System.Threading; using System.Threading.Tasks; @@ -6,7 +5,7 @@ using Dapper; using Microsoft.EntityFrameworkCore; using Microsoft.Extensions.Logging; -namespace DotNetCore.CAP.EntityFrameworkCore +namespace DotNetCore.CAP.SqlServer { public class SqlServerStorage : IStorage { diff --git a/src/DotNetCore.CAP.EntityFrameworkCore/SqlServerStorageConnection.cs b/src/DotNetCore.CAP.EntityFrameworkCore/SqlServerStorageConnection.cs index 6dd326a..78c2a2e 100644 --- a/src/DotNetCore.CAP.EntityFrameworkCore/SqlServerStorageConnection.cs +++ b/src/DotNetCore.CAP.EntityFrameworkCore/SqlServerStorageConnection.cs @@ -7,7 +7,7 @@ using DotNetCore.CAP.Infrastructure; using DotNetCore.CAP.Models; using Microsoft.EntityFrameworkCore; -namespace DotNetCore.CAP.EntityFrameworkCore +namespace DotNetCore.CAP.SqlServer { public class SqlServerStorageConnection : IStorageConnection { @@ -15,7 +15,7 @@ namespace DotNetCore.CAP.EntityFrameworkCore public SqlServerStorageConnection(SqlServerOptions options) { - _options = options; + _options = options; } public SqlServerOptions Options => _options; diff --git a/src/DotNetCore.CAP.EntityFrameworkCore/SqlServerStorageTransaction.cs b/src/DotNetCore.CAP.EntityFrameworkCore/SqlServerStorageTransaction.cs index 81dd805..f1421b1 100644 --- a/src/DotNetCore.CAP.EntityFrameworkCore/SqlServerStorageTransaction.cs +++ b/src/DotNetCore.CAP.EntityFrameworkCore/SqlServerStorageTransaction.cs @@ -5,7 +5,7 @@ using System.Threading.Tasks; using Dapper; using DotNetCore.CAP.Models; -namespace DotNetCore.CAP.EntityFrameworkCore +namespace DotNetCore.CAP.SqlServer { public class SqlServerStorageTransaction : IStorageTransaction, IDisposable { diff --git a/test/DotNetCore.CAP.EntityFrameworkCore.Test/DotNetCore.CAP.EntityFrameworkCore.Test.csproj b/test/DotNetCore.CAP.EntityFrameworkCore.Test/DotNetCore.CAP.EntityFrameworkCore.Test.csproj index 8a35540..53b28ec 100644 --- a/test/DotNetCore.CAP.EntityFrameworkCore.Test/DotNetCore.CAP.EntityFrameworkCore.Test.csproj +++ b/test/DotNetCore.CAP.EntityFrameworkCore.Test/DotNetCore.CAP.EntityFrameworkCore.Test.csproj @@ -18,8 +18,8 @@ + -