diff --git a/src/Pole.ReliableMessage.Storage.Abstraction/IMemberShipTable.cs b/src/Pole.ReliableMessage.Storage.Abstraction/IMemberShipTableManager.cs
similarity index 95%
rename from src/Pole.ReliableMessage.Storage.Abstraction/IMemberShipTable.cs
rename to src/Pole.ReliableMessage.Storage.Abstraction/IMemberShipTableManager.cs
index 9f9b1ed..46ef040 100644
--- a/src/Pole.ReliableMessage.Storage.Abstraction/IMemberShipTable.cs
+++ b/src/Pole.ReliableMessage.Storage.Abstraction/IMemberShipTableManager.cs
@@ -6,7 +6,7 @@ using System.Threading.Tasks;
 
 namespace Pole.ReliableMessage.Storage.Abstraction
 {
-    public interface IMemberShipTable
+    public interface IMemberShipTableManager
     {
         Task<bool> IsPendingMessageCheckerServiceInstance(string ipAddress);
         Task<bool> UpdateIAmAlive(string ipAddress, DateTime dateTime);
diff --git a/src/Pole.ReliableMessage.Storage.Mongodb/MongodbMemberShipTable.cs b/src/Pole.ReliableMessage.Storage.Mongodb/MongodbMemberShipTableManager.cs
similarity index 96%
rename from src/Pole.ReliableMessage.Storage.Mongodb/MongodbMemberShipTable.cs
rename to src/Pole.ReliableMessage.Storage.Mongodb/MongodbMemberShipTableManager.cs
index 72f8ee4..6350b55 100644
--- a/src/Pole.ReliableMessage.Storage.Mongodb/MongodbMemberShipTable.cs
+++ b/src/Pole.ReliableMessage.Storage.Mongodb/MongodbMemberShipTableManager.cs
@@ -12,12 +12,12 @@ using Pole.ReliableMessage.Storage.Abstraction;
 
 namespace Pole.ReliableMessage.Storage.Mongodb
 {
-    class MongodbMemberShipTable : IMemberShipTable
+    class MongodbMemberShipTableManager : IMemberShipTableManager
     {
         private readonly MongoClient _mongoClient;
         private readonly MongodbOption _mongodbOption;
         private readonly ILogger _logger;
-        public MongodbMemberShipTable(IConfiguration configuration, MongoClient mongoClient, IOptions<MongodbOption> mongodbOption, ILogger<MongodbMemberShipTable> logger)
+        public MongodbMemberShipTableManager(IConfiguration configuration, MongoClient mongoClient, IOptions<MongodbOption> mongodbOption, ILogger<MongodbMemberShipTableManager> logger)
         {
             _mongoClient = mongoClient;
             _mongodbOption = mongodbOption.Value;
diff --git a/src/Pole.ReliableMessage.Storage.Mongodb/ReliableMessageOptionExtension.cs b/src/Pole.ReliableMessage.Storage.Mongodb/ReliableMessageOptionExtension.cs
index 13c51a4..e33c8c7 100644
--- a/src/Pole.ReliableMessage.Storage.Mongodb/ReliableMessageOptionExtension.cs
+++ b/src/Pole.ReliableMessage.Storage.Mongodb/ReliableMessageOptionExtension.cs
@@ -35,7 +35,7 @@ namespace Microsoft.Extensions.DependencyInjection
         {
             services.Configure(_mongodbOption);
             services.AddSingleton<IMessageStorage, MongodbMessageStorage>();
-            services.AddSingleton<IMemberShipTable, MongodbMemberShipTable>();
+            services.AddSingleton<IMemberShipTableManager, MongodbMemberShipTableManager>();
 
             var mongodbOption = services.BuildServiceProvider().GetRequiredService<IOptions<MongodbOption>>().Value;
 
diff --git a/src/Pole.ReliableMessage/Processor/MessageCleanProcessor.cs b/src/Pole.ReliableMessage/Processor/MessageCleanProcessor.cs
index 6396e14..7f176b1 100644
--- a/src/Pole.ReliableMessage/Processor/MessageCleanProcessor.cs
+++ b/src/Pole.ReliableMessage/Processor/MessageCleanProcessor.cs
@@ -15,9 +15,9 @@ namespace Pole.ReliableMessage.Processor
         private readonly ReliableMessageOption _options;
         private readonly ILogger<MessageCleanProcessor> _logger;
         private readonly IMessageStorage _messageStorage;
-        private readonly IMemberShipTable _memberShipTable;
+        private readonly IMemberShipTableManager _memberShipTable;
         private readonly IServiceIPv4AddressProvider _serviceIPv4AddressProvider;
-        public MessageCleanProcessor(IOptions<ReliableMessageOption> options, ILogger<MessageCleanProcessor> logger, IMessageStorage messageStorage, IMemberShipTable memberShipTable, IServiceIPv4AddressProvider serviceIPv4AddressProvider)
+        public MessageCleanProcessor(IOptions<ReliableMessageOption> options, ILogger<MessageCleanProcessor> logger, IMessageStorage messageStorage, IMemberShipTableManager memberShipTable, IServiceIPv4AddressProvider serviceIPv4AddressProvider)
         {
             _options = options.Value ?? throw new Exception($"{nameof(ReliableMessageOption)} Must be injected");
             _logger = logger;
diff --git a/src/Pole.ReliableMessage/Processor/PendingMessageCheckProcessor.cs b/src/Pole.ReliableMessage/Processor/PendingMessageCheckProcessor.cs
index 224c221..c72b3e1 100644
--- a/src/Pole.ReliableMessage/Processor/PendingMessageCheckProcessor.cs
+++ b/src/Pole.ReliableMessage/Processor/PendingMessageCheckProcessor.cs
@@ -19,11 +19,11 @@ namespace Pole.ReliableMessage.Processor
         private readonly ReliableMessageOption _options;
         //private readonly IMessageBuffer _messageBuffer;
         private readonly ITimeHelper _timeHelper;
-        private readonly IMemberShipTable _memberShipTable;
+        private readonly IMemberShipTableManager _memberShipTable;
         private readonly ILogger<PendingMessageCheckProcessor> _logger;
         private readonly IServiceIPv4AddressProvider _serviceIPv4AddressProvider;
         private readonly IMessageCheckRetryer _messageCheckRetryer;
-        public PendingMessageCheckProcessor(IMessageStorage storage, IOptions<ReliableMessageOption> options, ITimeHelper timeHelper, IMemberShipTable memberShipTable, ILogger<PendingMessageCheckProcessor> logger, IServiceIPv4AddressProvider serviceIPv4AddressProvider, IMessageCheckRetryer messageCheckRetryer)
+        public PendingMessageCheckProcessor(IMessageStorage storage, IOptions<ReliableMessageOption> options, ITimeHelper timeHelper, IMemberShipTableManager memberShipTable, ILogger<PendingMessageCheckProcessor> logger, IServiceIPv4AddressProvider serviceIPv4AddressProvider, IMessageCheckRetryer messageCheckRetryer)
         {
             _storage = storage;
             _options = options.Value ?? throw new Exception($"{nameof(ReliableMessageOption)} Must be injected");
diff --git a/src/Pole.ReliableMessage/Processor/PendingMessageServiceInstanceCheckProcessor.cs b/src/Pole.ReliableMessage/Processor/PendingMessageServiceInstanceCheckProcessor.cs
index a1d1e6d..07696b9 100644
--- a/src/Pole.ReliableMessage/Processor/PendingMessageServiceInstanceCheckProcessor.cs
+++ b/src/Pole.ReliableMessage/Processor/PendingMessageServiceInstanceCheckProcessor.cs
@@ -14,10 +14,10 @@ namespace Pole.ReliableMessage.Processor
     {
         private readonly ReliableMessageOption _options;
         private readonly ITimeHelper _timeHelper;
-        private readonly IMemberShipTable _memberShipTable;
+        private readonly IMemberShipTableManager _memberShipTable;
         private readonly ILogger<PendingMessageServiceInstanceCheckProcessor> _logger;
         private readonly IServiceIPv4AddressProvider _serviceIPv4AddressProvider;
-        public PendingMessageServiceInstanceCheckProcessor(IOptions<ReliableMessageOption> options, ITimeHelper timeHelper, IMemberShipTable memberShipTable, ILogger<PendingMessageServiceInstanceCheckProcessor> logger, IServiceIPv4AddressProvider serviceIPv4AddressProvider)
+        public PendingMessageServiceInstanceCheckProcessor(IOptions<ReliableMessageOption> options, ITimeHelper timeHelper, IMemberShipTableManager memberShipTable, ILogger<PendingMessageServiceInstanceCheckProcessor> logger, IServiceIPv4AddressProvider serviceIPv4AddressProvider)
         {
             _options = options.Value ?? throw new Exception($"{nameof(ReliableMessageOption)} Must be injected");
             _timeHelper = timeHelper;