@@ -43,7 +43,7 @@ public void flushAllTest() {
43
43
control .set ("k" + i , "v" + i );
44
44
}
45
45
46
- try (JedisPooled jedis = new JedisPooled (hnp , clientConfig .get (), CacheConfig .builder ().maxSize ( 1000 ). build ())) {
46
+ try (JedisPooled jedis = new JedisPooled (hnp , clientConfig .get (), CacheConfig .builder ().build ())) {
47
47
Cache cache = jedis .getCache ();
48
48
for (int i = 0 ; i < count ; i ++) {
49
49
jedis .get ("k" + i );
@@ -92,7 +92,7 @@ public void lruEvictionTest() {
92
92
93
93
@ Test // T.5.2
94
94
public void deleteByKeyUsingMGetTest () {
95
- try (JedisPooled jedis = new JedisPooled (hnp , clientConfig .get (), CacheConfig .builder ().maxSize ( 1000 ). build ())) {
95
+ try (JedisPooled jedis = new JedisPooled (hnp , clientConfig .get (), CacheConfig .builder ().build ())) {
96
96
Cache clientSideCache = jedis .getCache ();
97
97
98
98
jedis .set ("1" , "one" );
@@ -216,7 +216,7 @@ public void multiKeyOperation() {
216
216
control .set ("k1" , "v1" );
217
217
control .set ("k2" , "v2" );
218
218
219
- try (JedisPooled jedis = new JedisPooled (hnp , clientConfig .get (), CacheConfig .builder ().maxSize ( 1000 ). build ())) {
219
+ try (JedisPooled jedis = new JedisPooled (hnp , clientConfig .get (), CacheConfig .builder ().build ())) {
220
220
jedis .mget ("k1" , "k2" );
221
221
assertEquals (1 , jedis .getCache ().getSize ());
222
222
}
@@ -272,7 +272,7 @@ public void testInvalidationWithUnifiedJedis() {
272
272
public void differentInstanceOnEachCacheHit () {
273
273
274
274
// fill the cache for maxSize
275
- try (JedisPooled jedis = new JedisPooled (hnp , clientConfig .get (), CacheConfig .builder ().maxSize ( 1000 ). build ())) {
275
+ try (JedisPooled jedis = new JedisPooled (hnp , clientConfig .get (), CacheConfig .builder ().build ())) {
276
276
Cache cache = jedis .getCache ();
277
277
jedis .sadd ("foo" , "a" );
278
278
jedis .sadd ("foo" , "b" );
@@ -348,7 +348,7 @@ public void testConcurrentAccessWithStats() throws InterruptedException {
348
348
ExecutorService executorService = Executors .newFixedThreadPool (threadCount );
349
349
350
350
// Create the shared mock instance of cache
351
- try (JedisPooled jedis = new JedisPooled (endpoint .getHostAndPort (), clientConfig .get (), CacheConfig .builder ().maxSize ( 1000 ). build ())) {
351
+ try (JedisPooled jedis = new JedisPooled (endpoint .getHostAndPort (), clientConfig .get (), CacheConfig .builder ().build ())) {
352
352
Cache cache = jedis .getCache ();
353
353
// Submit multiple threads to perform concurrent operations
354
354
CountDownLatch latch = new CountDownLatch (threadCount );
@@ -385,7 +385,7 @@ public void testMaxSize() throws InterruptedException {
385
385
386
386
ExecutorService executorService = Executors .newFixedThreadPool (threadCount );
387
387
388
- try (JedisPooled jedis = new JedisPooled (endpoint .getHostAndPort (), clientConfig .get (), CacheConfig .builder ().maxSize (1000 ).build ())) {
388
+ try (JedisPooled jedis = new JedisPooled (endpoint .getHostAndPort (), clientConfig .get (), CacheConfig .builder ().maxSize (maxSize ).build ())) {
389
389
Cache testCache = jedis .getCache ();
390
390
// Submit multiple threads to perform concurrent operations
391
391
CountDownLatch latch = new CountDownLatch (threadCount );
0 commit comments