Pārlūkot izejas kodu

Zebus.Persistence: Rename Persistence.CQL assembly to Persistence.Cassandra for consistent naming between Directory and Persistence

Mathieu Stefani 3 gadi atpakaļ
vecāks
revīzija
34626abcee
37 mainītis faili ar 66 papildinājumiem un 66 dzēšanām
  1. 2 2
      src/Abc.Zebus.Persistence.Cassandra.Testing/Abc.Zebus.Persistence.Cassandra.Testing.csproj
  2. 3 3
      src/Abc.Zebus.Persistence.Cassandra.Testing/CassandraConfigurationMock.cs
  3. 0 0
      src/Abc.Zebus.Persistence.Cassandra.Testing/Properties/AssemblyInfo.cs
  4. 2 1
      src/Abc.Zebus.Persistence.Cassandra.Tests/Abc.Zebus.Persistence.Cassandra.Tests.csproj
  5. 1 1
      src/Abc.Zebus.Persistence.Cassandra.Tests/BucketIdHelperTests.cs
  6. 3 3
      src/Abc.Zebus.Persistence.Cassandra.Tests/Cql/CqlTestFixture.cs
  7. 4 4
      src/Abc.Zebus.Persistence.Cassandra.Tests/CqlMessageReaderTests.cs
  8. 4 4
      src/Abc.Zebus.Persistence.Cassandra.Tests/CqlStorageTests.cs
  9. 1 1
      src/Abc.Zebus.Persistence.Cassandra.Tests/MessageIdV2.cs
  10. 5 5
      src/Abc.Zebus.Persistence.Cassandra.Tests/OldestNonAckedMessageUpdaterPeriodicActionTests.cs
  11. 0 0
      src/Abc.Zebus.Persistence.Cassandra.Tests/Properties/AssemblyInfo.cs
  12. 1 1
      src/Abc.Zebus.Persistence.Cassandra/Abc.Zebus.Persistence.Cassandra.csproj
  13. 1 1
      src/Abc.Zebus.Persistence.Cassandra/Cql/CassandraCqlSessionManager.cs
  14. 1 1
      src/Abc.Zebus.Persistence.Cassandra/Cql/CqlDataContext.cs
  15. 2 2
      src/Abc.Zebus.Persistence.Cassandra/Cql/CqlMessageReader.cs
  16. 3 3
      src/Abc.Zebus.Persistence.Cassandra/Cql/CqlStorage.cs
  17. 2 2
      src/Abc.Zebus.Persistence.Cassandra/Cql/ICassandraConfiguration.cs
  18. 1 1
      src/Abc.Zebus.Persistence.Cassandra/Cql/ICqlStorage.cs
  19. 2 2
      src/Abc.Zebus.Persistence.Cassandra/Cql/PeerState.cs
  20. 2 2
      src/Abc.Zebus.Persistence.Cassandra/Cql/PeerStateRepository.cs
  21. 2 2
      src/Abc.Zebus.Persistence.Cassandra/Data/CassandraPeerState.cs
  22. 3 3
      src/Abc.Zebus.Persistence.Cassandra/Data/PersistenceCqlDataContext.cs
  23. 1 1
      src/Abc.Zebus.Persistence.Cassandra/Data/PersistentMessage.cs
  24. 2 2
      src/Abc.Zebus.Persistence.Cassandra/ICqlPersistenceConfiguration.cs
  25. 2 2
      src/Abc.Zebus.Persistence.Cassandra/PeriodicAction/OldestNonAckedMessageUpdaterPeriodicAction.cs
  26. 2 2
      src/Abc.Zebus.Persistence.Cassandra/Properties/AssemblyInfo.cs
  27. 1 1
      src/Abc.Zebus.Persistence.Cassandra/Util/MessageIdExtensions.cs
  28. 0 0
      src/Abc.Zebus.Persistence.Cassandra/schema/1.0/01_Create_PersistentMessage.cql
  29. 0 0
      src/Abc.Zebus.Persistence.Cassandra/schema/1.0/02_Create_PeerState.cql
  30. 0 0
      src/Abc.Zebus.Persistence.Cassandra/schema/1.1/01_Create_PersistentMessage.cql
  31. 1 1
      src/Abc.Zebus.Persistence.Runner/Abc.Zebus.Persistence.Runner.csproj
  32. 1 1
      src/Abc.Zebus.Persistence.Runner/CassandraAppSettingsConfiguration.cs
  33. 3 4
      src/Abc.Zebus.Persistence.Runner/Program.cs
  34. 2 2
      src/Abc.Zebus.Persistence/Properties/AssemblyInfo.cs
  35. 1 1
      src/Abc.Zebus.Testing/Properties/AssemblyInfo.cs
  36. 3 3
      src/Abc.Zebus.sln
  37. 2 2
      src/Abc.Zebus/Properties/AssemblyInfo.cs

+ 2 - 2
src/Abc.Zebus.Persistence.CQL.Testing/Abc.Zebus.Persistence.CQL.Testing.csproj → src/Abc.Zebus.Persistence.Cassandra.Testing/Abc.Zebus.Persistence.Cassandra.Testing.csproj

@@ -2,12 +2,12 @@
 
   <PropertyGroup>
     <TargetFramework>netstandard2.0</TargetFramework>
-    <PackageId>Zebus.Persistence.CQL.Testing</PackageId>
+    <PackageId>Zebus.Persistence.Cassandra.Testing</PackageId>
     <Version>$(ZebusPersistenceVersion)</Version>
   </PropertyGroup>
 
   <ItemGroup>
-    <ProjectReference Include="..\Abc.Zebus.Persistence.CQL\Abc.Zebus.Persistence.CQL.csproj" />
+    <ProjectReference Include="..\Abc.Zebus.Persistence.Cassandra\Abc.Zebus.Persistence.Cassandra.csproj" />
     <ProjectReference Include="..\Abc.Zebus.Persistence.Messages\Abc.Zebus.Persistence.Messages.csproj" PrivateAssets="All" />
   </ItemGroup>
 

+ 3 - 3
src/Abc.Zebus.Persistence.CQL.Testing/CassandraConfigurationMock.cs → src/Abc.Zebus.Persistence.Cassandra.Testing/CassandraConfigurationMock.cs

@@ -1,8 +1,8 @@
 using System;
-using Abc.Zebus.Persistence.CQL.Util;
+using Abc.Zebus.Persistence.Cassandra.Cql;
 using Moq;
 
-namespace Abc.Zebus.Persistence.CQL.Testing
+namespace Abc.Zebus.Persistence.Cassandra.Testing
 {
     // TODO: This entire namespace belongs in Zebus.Testing but it would require the creation of a Zebus.Shared, and we are not ready for that just yet
     public class CassandraConfigurationMock<TConfig> : Mock<TConfig> where TConfig : class, ICassandraConfiguration
@@ -15,4 +15,4 @@ namespace Abc.Zebus.Persistence.CQL.Testing
             As<ICassandraConfiguration>().SetupGet(config => config.LocalDataCenter).Returns(localDataCenter);
         }
     }
-}
+}

+ 0 - 0
src/Abc.Zebus.Persistence.CQL.Testing/Properties/AssemblyInfo.cs → src/Abc.Zebus.Persistence.Cassandra.Testing/Properties/AssemblyInfo.cs


+ 2 - 1
src/Abc.Zebus.Persistence.CQL.Tests/Abc.Zebus.Persistence.CQL.Tests.csproj → src/Abc.Zebus.Persistence.Cassandra.Tests/Abc.Zebus.Persistence.Cassandra.Tests.csproj

@@ -3,12 +3,13 @@
   <PropertyGroup>
     <TargetFrameworks>net48;net5.0</TargetFrameworks>
     <Version>$(ZebusPersistenceVersion)</Version>
+    <RootNamespace>Abc.Zebus.Persistence.Cassandra.Tests</RootNamespace>
   </PropertyGroup>
 
   <Import Project="..\Abc.Zebus.Tests.props" />
 
   <ItemGroup>
-    <ProjectReference Include="..\Abc.Zebus.Persistence.CQL.Testing\Abc.Zebus.Persistence.CQL.Testing.csproj" />
+    <ProjectReference Include="..\Abc.Zebus.Persistence.Cassandra.Testing\Abc.Zebus.Persistence.Cassandra.Testing.csproj" />
     <ProjectReference Include="..\Abc.Zebus.Persistence.Messages\Abc.Zebus.Persistence.Messages.csproj" PrivateAssets="All" />
     <ProjectReference Include="..\Abc.Zebus.Testing\Abc.Zebus.Testing.csproj" />
   </ItemGroup>

+ 1 - 1
src/Abc.Zebus.Persistence.CQL.Tests/BucketIdHelperTests.cs → src/Abc.Zebus.Persistence.Cassandra.Tests/BucketIdHelperTests.cs

@@ -3,7 +3,7 @@ using Abc.Zebus.Persistence.Messages;
 using Abc.Zebus.Testing.Extensions;
 using NUnit.Framework;
 
-namespace Abc.Zebus.Persistence.CQL.Tests
+namespace Abc.Zebus.Persistence.Cassandra.Tests
 {
     public class BucketIdHelperTests
     {

+ 3 - 3
src/Abc.Zebus.Persistence.CQL.Tests/Cql/CqlTestFixture.cs → src/Abc.Zebus.Persistence.Cassandra.Tests/Cql/CqlTestFixture.cs

@@ -2,14 +2,14 @@
 using System.Collections.Generic;
 using System.Diagnostics;
 using System.Reflection;
-using Abc.Zebus.Persistence.CQL.Testing;
-using Abc.Zebus.Persistence.CQL.Util;
+using Abc.Zebus.Persistence.Cassandra.Cql;
+using Abc.Zebus.Persistence.Cassandra.Testing;
 using Cassandra;
 using Cassandra.Mapping;
 using Moq;
 using NUnit.Framework;
 
-namespace Abc.Zebus.Persistence.CQL.Tests.Cql
+namespace Abc.Zebus.Persistence.Cassandra.Tests.Cql
 {
     // TODO: This entire namespace belongs in Zebus.Testing but it would require the creation of a Zebus.Shared, and we are not ready for that just yet
     public abstract class CqlTestFixture<TDataContext, TConfig>

+ 4 - 4
src/Abc.Zebus.Persistence.CQL.Tests/CqlMessageReaderTests.cs → src/Abc.Zebus.Persistence.Cassandra.Tests/CqlMessageReaderTests.cs

@@ -1,9 +1,9 @@
 using System;
 using System.IO;
 using System.Linq;
-using Abc.Zebus.Persistence.CQL.Data;
-using Abc.Zebus.Persistence.CQL.Storage;
-using Abc.Zebus.Persistence.CQL.Tests.Cql;
+using Abc.Zebus.Persistence.Cassandra.Cql;
+using Abc.Zebus.Persistence.Cassandra.Data;
+using Abc.Zebus.Persistence.Cassandra.Tests.Cql;
 using Abc.Zebus.Persistence.Messages;
 using Abc.Zebus.Persistence.Storage;
 using Abc.Zebus.Serialization;
@@ -12,7 +12,7 @@ using Abc.Zebus.Testing.Extensions;
 using Abc.Zebus.Transport;
 using NUnit.Framework;
 
-namespace Abc.Zebus.Persistence.CQL.Tests
+namespace Abc.Zebus.Persistence.Cassandra.Tests
 {
     public class CqlMessageReaderTests : CqlTestFixture<PersistenceCqlDataContext, ICqlPersistenceConfiguration>
     {

+ 4 - 4
src/Abc.Zebus.Persistence.CQL.Tests/CqlStorageTests.cs → src/Abc.Zebus.Persistence.Cassandra.Tests/CqlStorageTests.cs

@@ -2,9 +2,9 @@
 using System.Collections.Generic;
 using System.Linq;
 using System.Threading.Tasks;
-using Abc.Zebus.Persistence.CQL.Data;
-using Abc.Zebus.Persistence.CQL.Storage;
-using Abc.Zebus.Persistence.CQL.Tests.Cql;
+using Abc.Zebus.Persistence.Cassandra.Cql;
+using Abc.Zebus.Persistence.Cassandra.Data;
+using Abc.Zebus.Persistence.Cassandra.Tests.Cql;
 using Abc.Zebus.Persistence.Matching;
 using Abc.Zebus.Persistence.Messages;
 using Abc.Zebus.Persistence.Reporter;
@@ -17,7 +17,7 @@ using Moq;
 using NUnit.Framework;
 using ProtoBuf;
 
-namespace Abc.Zebus.Persistence.CQL.Tests
+namespace Abc.Zebus.Persistence.Cassandra.Tests
 {
     public class CqlStorageTests : CqlTestFixture<PersistenceCqlDataContext, ICqlPersistenceConfiguration>
     {

+ 1 - 1
src/Abc.Zebus.Persistence.CQL.Tests/MessageIdV2.cs → src/Abc.Zebus.Persistence.Cassandra.Tests/MessageIdV2.cs

@@ -1,7 +1,7 @@
 using System;
 using System.Security.Cryptography;
 
-namespace Abc.Zebus.Persistence.CQL.Tests
+namespace Abc.Zebus.Persistence.Cassandra.Tests
 {
     public static class MessageIdV2
     {

+ 5 - 5
src/Abc.Zebus.Persistence.CQL.Tests/OldestNonAckedMessageUpdaterPeriodicActionTests.cs → src/Abc.Zebus.Persistence.Cassandra.Tests/OldestNonAckedMessageUpdaterPeriodicActionTests.cs

@@ -2,17 +2,17 @@
 using System.Collections.Generic;
 using System.Linq;
 using System.Threading.Tasks;
-using Abc.Zebus.Persistence.CQL.Data;
-using Abc.Zebus.Persistence.CQL.PeriodicAction;
-using Abc.Zebus.Persistence.CQL.Storage;
-using Abc.Zebus.Persistence.CQL.Tests.Cql;
+using Abc.Zebus.Persistence.Cassandra.Cql;
+using Abc.Zebus.Persistence.Cassandra.Data;
+using Abc.Zebus.Persistence.Cassandra.PeriodicAction;
+using Abc.Zebus.Persistence.Cassandra.Tests.Cql;
 using Abc.Zebus.Testing;
 using Abc.Zebus.Testing.Extensions;
 using Abc.Zebus.Util;
 using Moq;
 using NUnit.Framework;
 
-namespace Abc.Zebus.Persistence.CQL.Tests
+namespace Abc.Zebus.Persistence.Cassandra.Tests
 {
     public class OldestNonAckedMessageUpdaterPeriodicActionTests : CqlTestFixture<PersistenceCqlDataContext, ICqlPersistenceConfiguration>
     {

+ 0 - 0
src/Abc.Zebus.Persistence.CQL.Tests/Properties/AssemblyInfo.cs → src/Abc.Zebus.Persistence.Cassandra.Tests/Properties/AssemblyInfo.cs


+ 1 - 1
src/Abc.Zebus.Persistence.CQL/Abc.Zebus.Persistence.CQL.csproj → src/Abc.Zebus.Persistence.Cassandra/Abc.Zebus.Persistence.Cassandra.csproj

@@ -2,7 +2,7 @@
 
   <PropertyGroup>
     <TargetFramework>netstandard2.0</TargetFramework>
-    <PackageId>Zebus.Persistence.CQL</PackageId>
+    <PackageId>Zebus.Persistence.Cassandra</PackageId>
     <Version>$(ZebusPersistenceVersion)</Version>
   </PropertyGroup>
 

+ 1 - 1
src/Abc.Zebus.Persistence.CQL/Util/CassandraCqlSessionManager.cs → src/Abc.Zebus.Persistence.Cassandra/Cql/CassandraCqlSessionManager.cs

@@ -3,7 +3,7 @@ using System.Collections.Concurrent;
 using System.Linq;
 using Cassandra;
 
-namespace Abc.Zebus.Persistence.CQL.Util
+namespace Abc.Zebus.Persistence.Cassandra.Cql
 {
     public class CassandraCqlSessionManager : IDisposable
     {

+ 1 - 1
src/Abc.Zebus.Persistence.CQL/Util/CqlDataContext.cs → src/Abc.Zebus.Persistence.Cassandra/Cql/CqlDataContext.cs

@@ -5,7 +5,7 @@ using Cassandra;
 using Cassandra.Data.Linq;
 using TableAttribute = Cassandra.Mapping.Attributes.TableAttribute;
 
-namespace Abc.Zebus.Persistence.CQL.Util
+namespace Abc.Zebus.Persistence.Cassandra.Cql
 {
     public abstract class CqlDataContext<TConfig> where TConfig : ICassandraConfiguration
     {

+ 2 - 2
src/Abc.Zebus.Persistence.CQL/Storage/CqlMessageReader.cs → src/Abc.Zebus.Persistence.Cassandra/Cql/CqlMessageReader.cs

@@ -1,14 +1,14 @@
 using System;
 using System.Collections.Generic;
 using System.Linq;
-using Abc.Zebus.Persistence.CQL.Data;
+using Abc.Zebus.Persistence.Cassandra.Data;
 using Abc.Zebus.Persistence.Messages;
 using Abc.Zebus.Persistence.Storage;
 using Cassandra;
 using Cassandra.Data.Linq;
 using log4net;
 
-namespace Abc.Zebus.Persistence.CQL.Storage
+namespace Abc.Zebus.Persistence.Cassandra.Cql
 {
     public class CqlMessageReader : IMessageReader
     {

+ 3 - 3
src/Abc.Zebus.Persistence.CQL/Storage/CqlStorage.cs → src/Abc.Zebus.Persistence.Cassandra/Cql/CqlStorage.cs

@@ -3,8 +3,8 @@ using System.Collections.Generic;
 using System.Linq;
 using System.Threading;
 using System.Threading.Tasks;
-using Abc.Zebus.Persistence.CQL.Data;
-using Abc.Zebus.Persistence.CQL.Util;
+using Abc.Zebus.Persistence.Cassandra.Data;
+using Abc.Zebus.Persistence.Cassandra.Util;
 using Abc.Zebus.Persistence.Matching;
 using Abc.Zebus.Persistence.Messages;
 using Abc.Zebus.Persistence.Reporter;
@@ -15,7 +15,7 @@ using Cassandra;
 using Cassandra.Data.Linq;
 using log4net;
 
-namespace Abc.Zebus.Persistence.CQL.Storage
+namespace Abc.Zebus.Persistence.Cassandra.Cql
 {
     public class CqlStorage : ICqlStorage, IDisposable
     {

+ 2 - 2
src/Abc.Zebus.Persistence.CQL/Util/ICassandraConfiguration.cs → src/Abc.Zebus.Persistence.Cassandra/Cql/ICassandraConfiguration.cs

@@ -1,6 +1,6 @@
 using System;
 
-namespace Abc.Zebus.Persistence.CQL.Util
+namespace Abc.Zebus.Persistence.Cassandra.Cql
 {
     public interface ICassandraConfiguration
     {
@@ -26,4 +26,4 @@ namespace Abc.Zebus.Persistence.CQL.Util
         /// </summary>
         string LocalDataCenter { get; }
     }
-}
+}

+ 1 - 1
src/Abc.Zebus.Persistence.CQL/Storage/ICqlStorage.cs → src/Abc.Zebus.Persistence.Cassandra/Cql/ICqlStorage.cs

@@ -2,7 +2,7 @@
 using System.Threading.Tasks;
 using Abc.Zebus.Persistence.Storage;
 
-namespace Abc.Zebus.Persistence.CQL.Storage
+namespace Abc.Zebus.Persistence.Cassandra.Cql
 {
     public interface ICqlStorage : IStorage
     {

+ 2 - 2
src/Abc.Zebus.Persistence.CQL/Storage/PeerState.cs → src/Abc.Zebus.Persistence.Cassandra/Cql/PeerState.cs

@@ -1,7 +1,7 @@
 using System;
 using Abc.Zebus.Util;
 
-namespace Abc.Zebus.Persistence.CQL.Storage
+namespace Abc.Zebus.Persistence.Cassandra.Cql
 {
     public class PeerState
     {
@@ -31,7 +31,7 @@ namespace Abc.Zebus.Persistence.CQL.Storage
 
         /// <summary>
         /// Provides a timestamp that is lower than or equal to the timestamp of the last unacked message.
-        /// 
+        ///
         /// The goal of this value is to  make replay efficient by using a recent starting point, thus reducing
         /// the number of messages that the replay will scan.
         /// </summary>

+ 2 - 2
src/Abc.Zebus.Persistence.CQL/Storage/PeerStateRepository.cs → src/Abc.Zebus.Persistence.Cassandra/Cql/PeerStateRepository.cs

@@ -2,7 +2,7 @@
 using System.Collections.Generic;
 using System.Linq;
 using System.Threading.Tasks;
-using Abc.Zebus.Persistence.CQL.Data;
+using Abc.Zebus.Persistence.Cassandra.Data;
 using Abc.Zebus.Persistence.Messages;
 using Abc.Zebus.Persistence.Util;
 using Abc.Zebus.Util;
@@ -10,7 +10,7 @@ using Cassandra;
 using Cassandra.Data.Linq;
 using log4net;
 
-namespace Abc.Zebus.Persistence.CQL.Storage
+namespace Abc.Zebus.Persistence.Cassandra.Cql
 {
     public class PeerStateRepository
     {

+ 2 - 2
src/Abc.Zebus.Persistence.CQL/Data/CassandraPeerState.cs → src/Abc.Zebus.Persistence.Cassandra/Data/CassandraPeerState.cs

@@ -1,7 +1,7 @@
-using Abc.Zebus.Persistence.CQL.Storage;
+using Abc.Zebus.Persistence.Cassandra.Cql;
 using Cassandra.Mapping.Attributes;
 
-namespace Abc.Zebus.Persistence.CQL.Data
+namespace Abc.Zebus.Persistence.Cassandra.Data
 {
     [Table("PeerState", CaseSensitive = true)]
     public class CassandraPeerState

+ 3 - 3
src/Abc.Zebus.Persistence.CQL/Data/PersistenceCqlDataContext.cs → src/Abc.Zebus.Persistence.Cassandra/Data/PersistenceCqlDataContext.cs

@@ -1,7 +1,7 @@
-using Abc.Zebus.Persistence.CQL.Util;
+using Abc.Zebus.Persistence.Cassandra.Cql;
 using Cassandra.Data.Linq;
 
-namespace Abc.Zebus.Persistence.CQL.Data
+namespace Abc.Zebus.Persistence.Cassandra.Data
 {
     public class PersistenceCqlDataContext : CqlDataContext<ICqlPersistenceConfiguration>
     {
@@ -12,4 +12,4 @@ namespace Abc.Zebus.Persistence.CQL.Data
         public Table<PersistentMessage> PersistentMessages => new Table<PersistentMessage>(Session);
         public Table<CassandraPeerState> PeerStates => new Table<CassandraPeerState>(Session);
     }
-}
+}

+ 1 - 1
src/Abc.Zebus.Persistence.CQL/Data/PersistentMessage.cs → src/Abc.Zebus.Persistence.Cassandra/Data/PersistentMessage.cs

@@ -1,7 +1,7 @@
 using System;
 using Cassandra.Mapping.Attributes;
 
-namespace Abc.Zebus.Persistence.CQL.Data
+namespace Abc.Zebus.Persistence.Cassandra.Data
 {
     [Table("PersistentMessage", CaseSensitive = true)]
     public class PersistentMessage

+ 2 - 2
src/Abc.Zebus.Persistence.CQL/ICqlPersistenceConfiguration.cs → src/Abc.Zebus.Persistence.Cassandra/ICqlPersistenceConfiguration.cs

@@ -1,7 +1,7 @@
 using System;
-using Abc.Zebus.Persistence.CQL.Util;
+using Abc.Zebus.Persistence.Cassandra.Cql;
 
-namespace Abc.Zebus.Persistence.CQL
+namespace Abc.Zebus.Persistence.Cassandra
 {
     public interface ICqlPersistenceConfiguration : ICassandraConfiguration
     {

+ 2 - 2
src/Abc.Zebus.Persistence.CQL/PeriodicAction/OldestNonAckedMessageUpdaterPeriodicAction.cs → src/Abc.Zebus.Persistence.Cassandra/PeriodicAction/OldestNonAckedMessageUpdaterPeriodicAction.cs

@@ -2,12 +2,12 @@
 using System.Linq;
 using System.Threading.Tasks;
 using Abc.Zebus.Hosting;
-using Abc.Zebus.Persistence.CQL.Storage;
+using Abc.Zebus.Persistence.Cassandra.Cql;
 using Abc.Zebus.Persistence.Storage;
 using Abc.Zebus.Util;
 using Abc.Zebus.Util.Extensions;
 
-namespace Abc.Zebus.Persistence.CQL.PeriodicAction
+namespace Abc.Zebus.Persistence.Cassandra.PeriodicAction
 {
     public class OldestNonAckedMessageUpdaterPeriodicAction : PeriodicActionHostInitializer
     {

+ 2 - 2
src/Abc.Zebus.Persistence.CQL/Properties/AssemblyInfo.cs → src/Abc.Zebus.Persistence.Cassandra/Properties/AssemblyInfo.cs

@@ -6,7 +6,7 @@ using System.Runtime.InteropServices;
 
 [assembly: InternalsVisibleTo("Abc.Zebus.Integration")]
 [assembly: InternalsVisibleTo("Abc.Zebus.PersistenceService.Tests")]
-[assembly: InternalsVisibleTo("Abc.Zebus.Persistence.CQL.Testing")]
-[assembly: InternalsVisibleTo("Abc.Zebus.Persistence.CQL.Tests")]
+[assembly: InternalsVisibleTo("Abc.Zebus.Persistence.Cassandra.Testing")]
+[assembly: InternalsVisibleTo("Abc.Zebus.Persistence.Cassandra.Tests")]
 
 [module: SkipLocalsInit]

+ 1 - 1
src/Abc.Zebus.Persistence.CQL/Util/MessageIdExtensions.cs → src/Abc.Zebus.Persistence.Cassandra/Util/MessageIdExtensions.cs

@@ -1,6 +1,6 @@
 using System;
 
-namespace Abc.Zebus.Persistence.CQL.Util
+namespace Abc.Zebus.Persistence.Cassandra.Util
 {
     public static class MessageIdExtensions
     {

+ 0 - 0
src/Abc.Zebus.Persistence.CQL/schema/1.0/01_Create_PersistentMessage.cql → src/Abc.Zebus.Persistence.Cassandra/schema/1.0/01_Create_PersistentMessage.cql


+ 0 - 0
src/Abc.Zebus.Persistence.CQL/schema/1.0/02_Create_PeerState.cql → src/Abc.Zebus.Persistence.Cassandra/schema/1.0/02_Create_PeerState.cql


+ 0 - 0
src/Abc.Zebus.Persistence.CQL/schema/1.1/01_Create_PersistentMessage.cql → src/Abc.Zebus.Persistence.Cassandra/schema/1.1/01_Create_PersistentMessage.cql


+ 1 - 1
src/Abc.Zebus.Persistence.Runner/Abc.Zebus.Persistence.Runner.csproj

@@ -8,7 +8,7 @@
   </PropertyGroup>
 
   <ItemGroup>
-    <ProjectReference Include="..\Abc.Zebus.Persistence.CQL\Abc.Zebus.Persistence.CQL.csproj" />
+    <ProjectReference Include="..\Abc.Zebus.Persistence.Cassandra\Abc.Zebus.Persistence.Cassandra.csproj" />
     <ProjectReference Include="..\Abc.Zebus.Persistence.RocksDb\Abc.Zebus.Persistence.RocksDb.csproj" />
   </ItemGroup>
 

+ 1 - 1
src/Abc.Zebus.Persistence.Runner/CassandraAppSettingsConfiguration.cs

@@ -1,5 +1,5 @@
 using System;
-using Abc.Zebus.Persistence.CQL;
+using Abc.Zebus.Persistence.Cassandra;
 using FluentDate;
 
 namespace Abc.Zebus.Persistence.Runner

+ 3 - 4
src/Abc.Zebus.Persistence.Runner/Program.cs

@@ -6,10 +6,9 @@ using Abc.Zebus.Core;
 using Abc.Zebus.Directory;
 using Abc.Zebus.Dispatch;
 using Abc.Zebus.Monitoring;
-using Abc.Zebus.Persistence.CQL;
-using Abc.Zebus.Persistence.CQL.PeriodicAction;
-using Abc.Zebus.Persistence.CQL.Storage;
-using Abc.Zebus.Persistence.CQL.Util;
+using Abc.Zebus.Persistence.Cassandra;
+using Abc.Zebus.Persistence.Cassandra.Cql;
+using Abc.Zebus.Persistence.Cassandra.PeriodicAction;
 using Abc.Zebus.Persistence.Initialization;
 using Abc.Zebus.Persistence.Matching;
 using Abc.Zebus.Persistence.Reporter;

+ 2 - 2
src/Abc.Zebus.Persistence/Properties/AssemblyInfo.cs

@@ -5,7 +5,7 @@ using System.Runtime.InteropServices;
 [assembly: Guid("acc56b25-51e9-4864-8913-d36ba6d8ffab")]
 
 [assembly: InternalsVisibleTo("Abc.Zebus.Persistence.Tests")]
-[assembly: InternalsVisibleTo("Abc.Zebus.Persistence.CQL")]
-[assembly: InternalsVisibleTo("Abc.Zebus.Persistence.CQL.Tests")]
+[assembly: InternalsVisibleTo("Abc.Zebus.Persistence.Cassandra")]
+[assembly: InternalsVisibleTo("Abc.Zebus.Persistence.Cassandra.Tests")]
 
 [module: SkipLocalsInit]

+ 1 - 1
src/Abc.Zebus.Testing/Properties/AssemblyInfo.cs

@@ -12,5 +12,5 @@ using System.Runtime.InteropServices;
 [assembly: InternalsVisibleTo("Abc.Zebus.Directory.Cassandra.Tests")]
 [assembly: InternalsVisibleTo("Abc.Zebus.Directory.RocksDb.Tests")]
 [assembly: InternalsVisibleTo("Abc.Zebus.Persistence.Tests")]
-[assembly: InternalsVisibleTo("Abc.Zebus.Persistence.CQL.Tests")]
+[assembly: InternalsVisibleTo("Abc.Zebus.Persistence.Cassandra.Tests")]
 [assembly: InternalsVisibleTo("Abc.Zebus.Persistence.RocksDb.Tests")]

+ 3 - 3
src/Abc.Zebus.sln

@@ -33,11 +33,11 @@ Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Abc.Zebus.Directory.Cassand
 EndProject
 Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Abc.Zebus.Directory.Tests", "Abc.Zebus.Directory.Tests\Abc.Zebus.Directory.Tests.csproj", "{7C004E59-3B24-4359-8E45-1CD93F03FD80}"
 EndProject
-Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Abc.Zebus.Persistence.CQL", "Abc.Zebus.Persistence.CQL\Abc.Zebus.Persistence.CQL.csproj", "{C59CFDDA-987B-4948-B016-95982BBE2CFA}"
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Abc.Zebus.Persistence.Cassandra", "Abc.Zebus.Persistence.Cassandra\Abc.Zebus.Persistence.Cassandra.csproj", "{C59CFDDA-987B-4948-B016-95982BBE2CFA}"
 EndProject
-Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Abc.Zebus.Persistence.CQL.Testing", "Abc.Zebus.Persistence.CQL.Testing\Abc.Zebus.Persistence.CQL.Testing.csproj", "{1059B7D5-1C8F-4702-A6DA-58986FB042F6}"
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Abc.Zebus.Persistence.Cassandra.Testing", "Abc.Zebus.Persistence.Cassandra.Testing\Abc.Zebus.Persistence.Cassandra.Testing.csproj", "{1059B7D5-1C8F-4702-A6DA-58986FB042F6}"
 EndProject
-Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Abc.Zebus.Persistence.CQL.Tests", "Abc.Zebus.Persistence.CQL.Tests\Abc.Zebus.Persistence.CQL.Tests.csproj", "{A9B86B14-A1D5-46F8-9F2D-777C204D7C0B}"
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Abc.Zebus.Persistence.Cassandra.Tests", "Abc.Zebus.Persistence.Cassandra.Tests\Abc.Zebus.Persistence.Cassandra.Tests.csproj", "{A9B86B14-A1D5-46F8-9F2D-777C204D7C0B}"
 EndProject
 Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Abc.Zebus.Persistence.Messages", "Abc.Zebus.Persistence.Messages\Abc.Zebus.Persistence.Messages.csproj", "{8FC5C46E-9C7F-4905-B8A8-89E154F576CF}"
 EndProject

+ 2 - 2
src/Abc.Zebus/Properties/AssemblyInfo.cs

@@ -21,8 +21,8 @@ using System.Runtime.InteropServices;
 [assembly: InternalsVisibleTo("Abc.Zebus.DirectoryService.Tests")]
 
 [assembly: InternalsVisibleTo("Abc.Zebus.Persistence")]
-[assembly: InternalsVisibleTo("Abc.Zebus.Persistence.CQL")]
-[assembly: InternalsVisibleTo("Abc.Zebus.Persistence.CQL.Tests")]
+[assembly: InternalsVisibleTo("Abc.Zebus.Persistence.Cassandra")]
+[assembly: InternalsVisibleTo("Abc.Zebus.Persistence.Cassandra.Tests")]
 [assembly: InternalsVisibleTo("Abc.Zebus.Persistence.RocksDb")]
 [assembly: InternalsVisibleTo("Abc.Zebus.Persistence.RocksDb.Tests")]
 [assembly: InternalsVisibleTo("Abc.Zebus.Persistence.Tests")]