From 5e13575e84e8853663e0c418303a69229e5070aa Mon Sep 17 00:00:00 2001
From: Redkale <22250530@qq.com>
Date: Thu, 9 Nov 2017 10:21:16 +0800
Subject: [PATCH]

---
 src/org/redkale/source/CacheMemorySource.java |  7 +------
 src/org/redkale/source/CacheSource.java       | 10 ----------
 2 files changed, 1 insertion(+), 16 deletions(-)

diff --git a/src/org/redkale/source/CacheMemorySource.java b/src/org/redkale/source/CacheMemorySource.java
index b3aa1f0dd..832554737 100644
--- a/src/org/redkale/source/CacheMemorySource.java
+++ b/src/org/redkale/source/CacheMemorySource.java
@@ -75,11 +75,6 @@ public class CacheMemorySource<V extends Object> extends AbstractService impleme
         this.needStore = !flag;
     }
 
-    @Override
-    public boolean isSupportQueryList() {
-        return true;
-    }
-
     @Override
     public void init(AnyValue conf) {
         if (this.convert == null) this.convert = this.defaultConvert;
@@ -160,7 +155,7 @@ public class CacheMemorySource<V extends Object> extends AbstractService impleme
         }
         if (remoteSource != null && !Sncp.isRemote(this)) {
             SncpClient client = Sncp.getSncpClient((Service) remoteSource);
-            if (client != null && client.getRemoteGroupTransport() != null && remoteSource.isSupportQueryList()) {
+            if (client != null && client.getRemoteGroupTransport() != null) {
                 super.runAsync(() -> {
                     try {
                         CompletableFuture<List<CacheEntry<Object>>> listFuture = remoteSource.queryListAsync();
diff --git a/src/org/redkale/source/CacheSource.java b/src/org/redkale/source/CacheSource.java
index 9d2aef9a3..017b5e3f2 100644
--- a/src/org/redkale/source/CacheSource.java
+++ b/src/org/redkale/source/CacheSource.java
@@ -30,11 +30,6 @@ public interface CacheSource<V extends Object> {
         return true;
     }
 
-    //是否支持queryList 或  queryListAsync 方法
-    default boolean isSupportQueryList() {
-        return false;
-    }
-
     public boolean exists(final String key);
 
     public V get(final String key);
@@ -112,11 +107,6 @@ public interface CacheSource<V extends Object> {
         return CompletableFuture.completedFuture(isOpen());
     }
 
-    //是否支持queryList 或  queryListAsync 方法
-    default CompletableFuture<Boolean> isSupportQueryListAsync() {
-        return CompletableFuture.completedFuture(isSupportQueryList());
-    }
-
     public static enum CacheEntryType {
         OBJECT, SET, LIST;
     }