DATAKV-63
+ reset the selected db when the connection is closed
This commit is contained in:
@@ -129,6 +129,11 @@ public class JedisConnection implements RedisConnection {
|
||||
pool.returnBrokenResource(jedis);
|
||||
}
|
||||
else {
|
||||
// reset the connection
|
||||
if (dbIndex > 0) {
|
||||
select(0);
|
||||
}
|
||||
|
||||
pool.returnResource(jedis);
|
||||
}
|
||||
}
|
||||
|
||||
@@ -80,6 +80,11 @@ public class RjcConnection implements RedisConnection {
|
||||
public void close() throws DataAccessException {
|
||||
isClosed = true;
|
||||
|
||||
// reset the connection (in case a pool is being used)
|
||||
if (dbIndex > 0) {
|
||||
select(0);
|
||||
}
|
||||
|
||||
try {
|
||||
subscriber.close();
|
||||
session.close();
|
||||
|
||||
Reference in New Issue
Block a user