Package org.dotwebstack.framework.backend.postgres

Class ContextAwareConnectionPool

java.lang.Object

org.dotwebstack.framework.backend.postgres.ContextAwareConnectionPool

All Implemented Interfaces:

io.r2dbc.spi.Closeable, io.r2dbc.spi.ConnectionFactory, io.r2dbc.spi.Wrapped<io.r2dbc.spi.ConnectionFactory>, reactor.core.Disposable

public class ContextAwareConnectionPool
extends Object
implements io.r2dbc.spi.ConnectionFactory, reactor.core.Disposable, io.r2dbc.spi.Closeable, io.r2dbc.spi.Wrapped<io.r2dbc.spi.ConnectionFactory>

Nested Class Summary

Nested classes/interfaces inherited from interface reactor.core.Disposable

reactor.core.Disposable.Composite, reactor.core.Disposable.Swap

Field Summary

Fields

Modifier and Type	Field	Description
static String	CTX_CONNECTION_UUID

Constructor Summary

Constructors

Constructor	Description
ContextAwareConnectionPool(io.r2dbc.pool.ConnectionPool connectionPool)

Method Summary

Modifier and Type	Method	Description
void	cancelRequest(String uuid)
void	cleanUp(String uuid)
org.reactivestreams.Publisher<Void>	close()
org.reactivestreams.Publisher<? extends io.r2dbc.spi.Connection>	create()
void	dispose()
io.r2dbc.spi.ConnectionFactoryMetadata	getMetadata()
io.r2dbc.spi.ConnectionFactory	unwrap()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface reactor.core.Disposable

isDisposed

Methods inherited from interface io.r2dbc.spi.Wrapped

unwrap

Field Detail

CTX_CONNECTION_UUID

public static final String CTX_CONNECTION_UUID

See Also:

Constant Field Values

Constructor Detail

ContextAwareConnectionPool

public ContextAwareConnectionPool(io.r2dbc.pool.ConnectionPool connectionPool)

Method Detail

create

public org.reactivestreams.Publisher<? extends io.r2dbc.spi.Connection> create()

Specified by:

create in interface io.r2dbc.spi.ConnectionFactory

cancelRequest

public void cancelRequest(String uuid)

cleanUp

public void cleanUp(String uuid)

getMetadata

public io.r2dbc.spi.ConnectionFactoryMetadata getMetadata()

Specified by:

getMetadata in interface io.r2dbc.spi.ConnectionFactory

close

public org.reactivestreams.Publisher<Void> close()

Specified by:

close in interface io.r2dbc.spi.Closeable

unwrap

public io.r2dbc.spi.ConnectionFactory unwrap()

Specified by:

unwrap in interface io.r2dbc.spi.Wrapped<io.r2dbc.spi.ConnectionFactory>

dispose

public void dispose()

Specified by:

dispose in interface reactor.core.Disposable