remove some api.

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();

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();

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()

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)
         {

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

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