super();
this.client = client;
this.dbIndex = dbIndex;
}
@Override
<BUG>public void activateObject(PooledObject<RedisAsyncConnection> pooledObject) throws Exception {

pooledObject.getObject().select(dbIndex);
}
public void destroyObject(final PooledObject<RedisAsyncConnection> obj) throws Exception {
</BUG>
try {

super();
this.client = client;
this.dbIndex = dbIndex;
}
@Override
public void activateObject(PooledObject<StatefulConnection<byte[], byte[]>> pooledObject) throws Exception {
if (pooledObject.getObject() instanceof StatefulRedisConnection) {
((StatefulRedisConnection) pooledObject.getObject()).sync().select(dbIndex);
}
}
public void destroyObject(final PooledObject<StatefulConnection<byte[], byte[]>> obj) throws Exception {
try {
