Package org.dotwebstack.framework.backend.postgres

Class ContextAwareConnectionPool

java.lang.Object

org.dotwebstack.framework.backend.postgres.ContextAwareConnectionPool

All Implemented Interfaces:

io.r2dbc.spi.ConnectionFactory

public class ContextAwareConnectionPool
extends Object
implements io.r2dbc.spi.ConnectionFactory

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<? extends io.r2dbc.spi.Connection>	create()
io.r2dbc.spi.ConnectionFactoryMetadata	getMetadata()

Methods inherited from class java.lang.Object

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

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