public class DelegatingConnectionFactory extends Object implements io.r2dbc.spi.ConnectionFactory, io.r2dbc.spi.Wrapped<io.r2dbc.spi.ConnectionFactory>
ConnectionFactory
implementation that delegates
all calls to a given target ConnectionFactory
.
This class is meant to be subclassed, with subclasses overriding
only those methods (such as create()
) that should not simply
delegate to the target ConnectionFactory
.
create()
Constructor and Description |
---|
DelegatingConnectionFactory(io.r2dbc.spi.ConnectionFactory targetConnectionFactory) |
Modifier and Type | Method and Description |
---|---|
reactor.core.publisher.Mono<? extends io.r2dbc.spi.Connection> |
create() |
io.r2dbc.spi.ConnectionFactoryMetadata |
getMetadata() |
io.r2dbc.spi.ConnectionFactory |
getTargetConnectionFactory() |
protected io.r2dbc.spi.ConnectionFactory |
obtainTargetConnectionFactory()
Obtain the target
ConnectionFactory for actual use (never null ). |
io.r2dbc.spi.ConnectionFactory |
unwrap() |
public DelegatingConnectionFactory(io.r2dbc.spi.ConnectionFactory targetConnectionFactory)
public reactor.core.publisher.Mono<? extends io.r2dbc.spi.Connection> create()
create
in interface io.r2dbc.spi.ConnectionFactory
public io.r2dbc.spi.ConnectionFactory getTargetConnectionFactory()
public io.r2dbc.spi.ConnectionFactoryMetadata getMetadata()
getMetadata
in interface io.r2dbc.spi.ConnectionFactory
public io.r2dbc.spi.ConnectionFactory unwrap()
unwrap
in interface io.r2dbc.spi.Wrapped<io.r2dbc.spi.ConnectionFactory>
protected io.r2dbc.spi.ConnectionFactory obtainTargetConnectionFactory()
ConnectionFactory
for actual use (never null
).