parent
b62a011643
commit
d3e8d1533f
|
@ -1389,7 +1389,7 @@ bom {
|
||||||
]
|
]
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
library("R2DBC Bom", "Arabba-SR9") {
|
library("R2DBC Bom", "Arabba-SR10") {
|
||||||
group("io.r2dbc") {
|
group("io.r2dbc") {
|
||||||
imports = [
|
imports = [
|
||||||
"r2dbc-bom"
|
"r2dbc-bom"
|
||||||
|
|
|
@ -231,6 +231,8 @@ public final class ConnectionFactoryBuilder {
|
||||||
ConnectionFactory connectionFactory) {
|
ConnectionFactory connectionFactory) {
|
||||||
ConnectionPoolConfiguration.Builder builder = ConnectionPoolConfiguration.builder(connectionFactory);
|
ConnectionPoolConfiguration.Builder builder = ConnectionPoolConfiguration.builder(connectionFactory);
|
||||||
PropertyMapper map = PropertyMapper.get().alwaysApplyingWhenNonNull();
|
PropertyMapper map = PropertyMapper.get().alwaysApplyingWhenNonNull();
|
||||||
|
map.from((Object) options.getValue(PoolingConnectionFactoryProvider.BACKGROUND_EVICTION_INTERVAL))
|
||||||
|
.as(this::toDuration).to(builder::backgroundEvictionInterval);
|
||||||
map.from((Object) options.getValue(PoolingConnectionFactoryProvider.INITIAL_SIZE)).as(this::toInteger)
|
map.from((Object) options.getValue(PoolingConnectionFactoryProvider.INITIAL_SIZE)).as(this::toInteger)
|
||||||
.to(builder::initialSize);
|
.to(builder::initialSize);
|
||||||
map.from((Object) options.getValue(PoolingConnectionFactoryProvider.MAX_SIZE)).as(this::toInteger)
|
map.from((Object) options.getValue(PoolingConnectionFactoryProvider.MAX_SIZE)).as(this::toInteger)
|
||||||
|
|
|
@ -232,6 +232,9 @@ class ConnectionFactoryBuilderTests {
|
||||||
|
|
||||||
ACQUIRE_RETRY(PoolingConnectionFactoryProvider.ACQUIRE_RETRY, 4, "acquireRetry"),
|
ACQUIRE_RETRY(PoolingConnectionFactoryProvider.ACQUIRE_RETRY, 4, "acquireRetry"),
|
||||||
|
|
||||||
|
BACKGROUND_EVICTION_INTERVAL(PoolingConnectionFactoryProvider.BACKGROUND_EVICTION_INTERVAL,
|
||||||
|
Duration.ofSeconds(120), "backgroundEvictionInterval"),
|
||||||
|
|
||||||
INITIAL_SIZE(PoolingConnectionFactoryProvider.INITIAL_SIZE, 2, "initialSize"),
|
INITIAL_SIZE(PoolingConnectionFactoryProvider.INITIAL_SIZE, 2, "initialSize"),
|
||||||
|
|
||||||
MAX_SIZE(PoolingConnectionFactoryProvider.MAX_SIZE, 8, "maxSize"),
|
MAX_SIZE(PoolingConnectionFactoryProvider.MAX_SIZE, 8, "maxSize"),
|
||||||
|
|
Loading…
Reference in New Issue