internalPool.invalidateObject(resource);
} catch (Exception e) {
throw new PoolException("Could not invalidate the broken resource", e);
}
}
<BUG>public void returnResource(final RedisAsyncConnection<byte[], byte[]> resource) {
</BUG>
try {
internalPool.returnObject(resource);
} catch (Exception e) {

internalPool.invalidateObject(resource);
} catch (Exception e) {
throw new PoolException("Could not invalidate the broken resource", e);
}
}
public void returnResource(final StatefulConnection<byte[], byte[]> resource) {
try {
internalPool.returnObject(resource);
} catch (Exception e) {
