return internalPool.borrowObject();
} catch (Exception e) {
throw new PoolException("Could not get a resource from the pool", e);
}
}
<BUG>public void returnBrokenResource(final RedisAsyncConnection<byte[], byte[]> resource) {
</BUG>
try {
internalPool.invalidateObject(resource);
} catch (Exception e) {

return internalPool.borrowObject();
} catch (Exception e) {
throw new PoolException("Could not get a resource from the pool", e);
}
}
public void returnBrokenResource(final StatefulConnection<byte[], byte[]> resource) {
try {
internalPool.invalidateObject(resource);
} catch (Exception e) {
