jinql
/
tomcat-cluster-redis-session-manager
mirror of https://github.com/ran-jit/tomcat-cluster-redis-session-manager
1
0
Fork 0
Code Issues Releases Wiki Activity

Update..

pull/27/head
Ranjith Manickam 2018-07-12 15:39:01 +05:30
parent a5dbb89e0d
commit 3e7d764356
1 changed files with 5 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
src/main/java/tomcat/request/session/data/cache/impl/RedisCacheUtil.java vendored
View File

@ -40,10 +40,8 @@ class RedisCacheUtil implements DataCache {
String retVal = null; String retVal = null;
do { do {
tries++; tries++;
try { try (Jedis jedis = pool.getResource()) {
Jedis jedis = pool.getResource();
retVal = jedis.set(key.getBytes(), value); retVal = jedis.set(key.getBytes(), value);
jedis.close();
sucess = true; sucess = true;
} catch (JedisConnectionException ex) { } catch (JedisConnectionException ex) {
log.error(RedisConstants.CONN_FAILED_RETRY_MSG + tries); log.error(RedisConstants.CONN_FAILED_RETRY_MSG + tries);
@ -65,10 +63,8 @@ class RedisCacheUtil implements DataCache {
Long retVal = null; Long retVal = null;
do { do {
tries++; tries++;
try { try (Jedis jedis = pool.getResource()) {
Jedis jedis = pool.getResource();
retVal = jedis.setnx(key.getBytes(), value); retVal = jedis.setnx(key.getBytes(), value);
jedis.close();
sucess = true; sucess = true;
} catch (JedisConnectionException ex) { } catch (JedisConnectionException ex) {
log.error(RedisConstants.CONN_FAILED_RETRY_MSG + tries); log.error(RedisConstants.CONN_FAILED_RETRY_MSG + tries);
@ -90,10 +86,8 @@ class RedisCacheUtil implements DataCache {
Long retVal = null; Long retVal = null;
do { do {
tries++; tries++;
try { try (Jedis jedis = pool.getResource()) {
Jedis jedis = pool.getResource();
retVal = jedis.expire(key, seconds); retVal = jedis.expire(key, seconds);
jedis.close();
sucess = true; sucess = true;
} catch (JedisConnectionException ex) { } catch (JedisConnectionException ex) {
log.error(RedisConstants.CONN_FAILED_RETRY_MSG + tries); log.error(RedisConstants.CONN_FAILED_RETRY_MSG + tries);
@ -115,10 +109,8 @@ class RedisCacheUtil implements DataCache {
byte[] retVal = null; byte[] retVal = null;
do { do {
tries++; tries++;
try { try (Jedis jedis = pool.getResource()) {
Jedis jedis = pool.getResource();
retVal = jedis.get(key.getBytes()); retVal = jedis.get(key.getBytes());
jedis.close();
sucess = true; sucess = true;
} catch (JedisConnectionException ex) { } catch (JedisConnectionException ex) {
log.error(RedisConstants.CONN_FAILED_RETRY_MSG + tries); log.error(RedisConstants.CONN_FAILED_RETRY_MSG + tries);
@ -140,10 +132,8 @@ class RedisCacheUtil implements DataCache {
Long retVal = null; Long retVal = null;
do { do {
tries++; tries++;
try { try (Jedis jedis = pool.getResource()) {
Jedis jedis = pool.getResource();
retVal = jedis.del(key); retVal = jedis.del(key);
jedis.close();
sucess = true; sucess = true;
} catch (JedisConnectionException ex) { } catch (JedisConnectionException ex) {
log.error(RedisConstants.CONN_FAILED_RETRY_MSG + tries); log.error(RedisConstants.CONN_FAILED_RETRY_MSG + tries);