|
18 | 18 | import com.couchbase.client.java.CouchbaseCluster; |
19 | 19 | import com.couchbase.client.java.datastructures.collections.CouchbaseArrayList; |
20 | 20 | import com.couchbase.client.java.datastructures.collections.CouchbaseArraySet; |
| 21 | +import com.couchbase.client.java.document.json.JsonValue; |
21 | 22 | import org.jnosql.diana.couchbase.util.CouchbaseClusterUtil; |
22 | 23 |
|
23 | 24 | import java.util.List; |
@@ -96,7 +97,7 @@ public <T> Queue<T> getQueue(String bucketName, Class<T> clazz) { |
96 | 97 | public <T> Set<T> getSet(String bucketName, Class<T> clazz) { |
97 | 98 | requireNonNull(bucketName, "bucketName is required"); |
98 | 99 | requireNonNull(clazz, "valueValue is required"); |
99 | | - if (JsonValueCheck.checkType(clazz)) { |
| 100 | + if (JsonValueCheck.checkType(clazz) && !JsonValue.class.isAssignableFrom(clazz)) { |
100 | 101 | return new CouchbaseArraySet<>(bucketName + SET, getBucket(bucketName)); |
101 | 102 | } else { |
102 | 103 | return new CouchbaseSet<>(getBucket(bucketName), bucketName, clazz); |
@@ -133,7 +134,7 @@ public <T> Set<T> getSet(String bucketName, String key, Class<T> clazz) { |
133 | 134 | requireNonNull(bucketName, "bucketName is required"); |
134 | 135 | requireNonNull(clazz, "valueValue is required"); |
135 | 136 | requireNonNull(key, "key is required"); |
136 | | - if (JsonValueCheck.checkType(clazz)) { |
| 137 | + if (JsonValueCheck.checkType(clazz) && !JsonValue.class.isAssignableFrom(clazz)) { |
137 | 138 | return new CouchbaseArraySet<>(bucketName + SET, getBucket(key)); |
138 | 139 | } else { |
139 | 140 | return new CouchbaseSet<>(getBucket(key), bucketName, clazz); |
|
0 commit comments