diff --git a/src/DotNetCore.CAP.MySql/MySqlStorageConnection.cs b/src/DotNetCore.CAP.MySql/MySqlStorageConnection.cs
index f1121e1..ae2efac 100644
--- a/src/DotNetCore.CAP.MySql/MySqlStorageConnection.cs
+++ b/src/DotNetCore.CAP.MySql/MySqlStorageConnection.cs
@@ -151,26 +151,11 @@ VALUES(@Name,@Group,@Content,@Retries,@Added,@ExpiresAt,@StatusName);";
             return new MySqlFetchedMessage(fetchedMessage.MessageId, fetchedMessage.MessageType, connection, transaction);
         }
 
-        public long GetSetCount(string key)
-        {
-            throw new NotImplementedException();
-        }
-
         public List<string> GetRangeFromSet(string key, int startingFrom, int endingAt)
         {
             throw new NotImplementedException();
         }
 
-        public MessageData GetJobData(string jobId)
-        {
-            throw new NotImplementedException();
-        }
-
-        public StateData GetStateData(string jobId)
-        {
-            throw new NotImplementedException();
-        }
-
         public bool ChangePublishedState(int messageId, IState state)
         {
             throw new NotImplementedException();
diff --git a/src/DotNetCore.CAP.PostgreSql/PostgreSqlStorageConnection.cs b/src/DotNetCore.CAP.PostgreSql/PostgreSqlStorageConnection.cs
index f79d3de..59286ab 100644
--- a/src/DotNetCore.CAP.PostgreSql/PostgreSqlStorageConnection.cs
+++ b/src/DotNetCore.CAP.PostgreSql/PostgreSqlStorageConnection.cs
@@ -135,26 +135,11 @@ namespace DotNetCore.CAP.PostgreSql
             return new PostgreSqlFetchedMessage(fetchedMessage.MessageId, fetchedMessage.MessageType, connection, transaction);
         }
 
-        public long GetSetCount(string key)
-        {
-            throw new NotImplementedException();
-        }
-
         public List<string> GetRangeFromSet(string key, int startingFrom, int endingAt)
         {
             throw new NotImplementedException();
         }
 
-        public MessageData GetJobData(string jobId)
-        {
-            throw new NotImplementedException();
-        }
-
-        public StateData GetStateData(string jobId)
-        {
-            throw new NotImplementedException();
-        }
-
         public bool ChangePublishedState(int messageId, IState state)
         {
             throw new NotImplementedException();
diff --git a/src/DotNetCore.CAP.SqlServer/SqlServerMonitoringApi.cs b/src/DotNetCore.CAP.SqlServer/SqlServerMonitoringApi.cs
index 741ca39..e11e4b2 100644
--- a/src/DotNetCore.CAP.SqlServer/SqlServerMonitoringApi.cs
+++ b/src/DotNetCore.CAP.SqlServer/SqlServerMonitoringApi.cs
@@ -72,9 +72,10 @@ _options.Schema);
                  GetHourlyTimelineStats(connection, "succeeded"));
         }
 
-        public IList<ServerDto> Servers()
+        public IList<SubscriberDto> Subscribers()
         {
-            return new List<ServerDto>();
+           // MethodMatcherCache
+            return new List<SubscriberDto>();
         }
 
         public IDictionary<DateTime, int> SucceededByDatesCount()
diff --git a/src/DotNetCore.CAP.SqlServer/SqlServerStorage.cs b/src/DotNetCore.CAP.SqlServer/SqlServerStorage.cs
index 8d4fd26..c0131b8 100644
--- a/src/DotNetCore.CAP.SqlServer/SqlServerStorage.cs
+++ b/src/DotNetCore.CAP.SqlServer/SqlServerStorage.cs
@@ -13,7 +13,7 @@ namespace DotNetCore.CAP.SqlServer
     {
         private readonly SqlServerOptions _options;
         private readonly ILogger _logger;
-        private readonly IDbConnection _existingConnection;
+        private readonly IDbConnection _existingConnection = null;
 
         public SqlServerStorage(ILogger<SqlServerStorage> logger, SqlServerOptions options)
         {
diff --git a/src/DotNetCore.CAP.SqlServer/SqlServerStorageConnection.cs b/src/DotNetCore.CAP.SqlServer/SqlServerStorageConnection.cs
index d106351..c5f407d 100644
--- a/src/DotNetCore.CAP.SqlServer/SqlServerStorageConnection.cs
+++ b/src/DotNetCore.CAP.SqlServer/SqlServerStorageConnection.cs
@@ -163,25 +163,9 @@ VALUES(@Name,@Group,@Content,@Retries,@Added,@ExpiresAt,@StatusName);";
 
         // ------------------------------------------
 
-        public long GetSetCount(string key)
-        {
-            return 11;
-        }
-
         public List<string> GetRangeFromSet(string key, int startingFrom, int endingAt)
         {
             return new List<string> { "11", "22", "33" };
         }
-
-        public MessageData GetJobData(string jobId)
-        {
-            return new MessageData();
-        }
-
-        public StateData GetStateData(string jobId)
-        {
-            return new StateData();
-        }
-
     }
 }
\ No newline at end of file
diff --git a/src/DotNetCore.CAP/IStorageConnection.cs b/src/DotNetCore.CAP/IStorageConnection.cs
index aca2726..0fe80fe 100644
--- a/src/DotNetCore.CAP/IStorageConnection.cs
+++ b/src/DotNetCore.CAP/IStorageConnection.cs
@@ -70,12 +70,7 @@ namespace DotNetCore.CAP
         bool ChangePublishedState(int messageId, IState state);
         bool ChangeReceivedState(int messageId, IState state);
 
-        long GetSetCount(string key);
-
         List<string> GetRangeFromSet(string key, int startingFrom, int endingAt);
 
-        MessageData GetJobData( string jobId);
-
-        StateData GetStateData(string jobId);
     }
 }
\ No newline at end of file