| Package | Description |
|---|---|
| org.davidmoten.rx.jdbc.pool |
| Modifier and Type | Method and Description |
|---|---|
static NonBlockingConnectionPool2.Builder |
NonBlockingConnectionPool2.builder() |
NonBlockingConnectionPool2.Builder |
NonBlockingConnectionPool2.Builder.connectionProvider(ConnectionProvider cp) |
NonBlockingConnectionPool2.Builder |
NonBlockingConnectionPool2.Builder.healthy(io.reactivex.functions.Predicate<Connection> healthy) |
NonBlockingConnectionPool2.Builder |
NonBlockingConnectionPool2.Builder.idleTimeBeforeHealthCheck(long value,
TimeUnit unit) |
NonBlockingConnectionPool2.Builder |
NonBlockingConnectionPool2.Builder.idleTimeBeforeHealthCheckMs(long value) |
NonBlockingConnectionPool2.Builder |
NonBlockingConnectionPool2.Builder.maxIdleTime(long value,
TimeUnit unit) |
NonBlockingConnectionPool2.Builder |
NonBlockingConnectionPool2.Builder.maxIdleTimeMs(long value) |
NonBlockingConnectionPool2.Builder |
NonBlockingConnectionPool2.Builder.maxPoolSize(int maxPoolSize)
Sets the maximum connection pool size.
|
static NonBlockingConnectionPool2.Builder |
Pools.nonBlocking() |
NonBlockingConnectionPool2.Builder |
NonBlockingConnectionPool2.Builder.returnToPoolDelayAfterHealthCheckFailure(long value,
TimeUnit unit) |
NonBlockingConnectionPool2.Builder |
NonBlockingConnectionPool2.Builder.returnToPoolDelayAfterHealthCheckFailureMs(long value) |
NonBlockingConnectionPool2.Builder |
NonBlockingConnectionPool2.Builder.scheduler(io.reactivex.Scheduler scheduler)
Sets the scheduler used for emitting connections (must be scheduled
to another thread to break the chain of stack calls otherwise can get
StackOverflowError) and for scheduling timeouts and retries.
|
NonBlockingConnectionPool2.Builder |
NonBlockingConnectionPool2.Builder.url(String url) |
Copyright © 2016–2017. All rights reserved.