public class DelegatingConnectionFactory extends Object implements ConnectionFactory, Wrapped<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(ConnectionFactory targetConnectionFactory) |
Modifier and Type | Method and Description |
---|---|
reactor.core.publisher.Mono<? extends Connection> |
create() |
ConnectionFactoryMetadata |
getMetadata() |
ConnectionFactory |
getTargetConnectionFactory()
Return the target
ConnectionFactory that this ConnectionFactory should delegate to. |
protected ConnectionFactory |
obtainTargetConnectionFactory()
Obtain the target
ConnectionFactory for actual use (never null). |
ConnectionFactory |
unwrap() |
public DelegatingConnectionFactory(ConnectionFactory targetConnectionFactory)
public reactor.core.publisher.Mono<? extends Connection> create()
create
in interface ConnectionFactory
@Nullable public ConnectionFactory getTargetConnectionFactory()
ConnectionFactory
that this ConnectionFactory
should delegate to.public ConnectionFactoryMetadata getMetadata()
getMetadata
in interface ConnectionFactory
public ConnectionFactory unwrap()
unwrap
in interface Wrapped<ConnectionFactory>
protected ConnectionFactory obtainTargetConnectionFactory()
ConnectionFactory
for actual use (never null).Copyright © 2018–2020 Pivotal Software, Inc.. All rights reserved.