Class DefaultConnectionStatus<C>

java.lang.Object

io.micronaut.data.connection.support.DefaultConnectionStatus<C>

Type Parameters:

C - The connection type

All Implemented Interfaces:

io.micronaut.core.propagation.PropagatedContextElement, ConnectionStatus<C>

@Internal
public final class DefaultConnectionStatus<C>
extends Object
implements ConnectionStatus<C>

The default propagated connection status.

Since:

4.0.0

Author:

Denis Stepanov

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	DefaultConnectionStatus.SuppliedConnection	The state of a connection supplied by the caller, whose owner may control its transaction.

Constructor Summary

Constructors

Constructor	Description
DefaultConnectionStatus(C connection, ConnectionDefinition definition, boolean isNew, ConnectionOperations<C> connectionOperations)
DefaultConnectionStatus(C connection, ConnectionDefinition definition, boolean isNew, ConnectionOperations<C> connectionOperations, @Nullable DefaultConnectionStatus.SuppliedConnection suppliedConnection)

Method Summary

Modifier and Type	Method	Description
void	afterClosed()
void	beforeClosed()
void	complete()
C	getConnection()	The connection representation.
ConnectionDefinition	getDefinition()	The connection definition.
@Nullable DefaultConnectionStatus.SuppliedConnection	getSuppliedConnection()
boolean	isConnectionOf(ConnectionOperations<C> connectionOperations)
boolean	isNew()	A new connection value.
boolean	isSupplied()
void	registerSynchronization(ConnectionSynchronization synchronization)	Register connection synchronization.

Methods inherited from class Object

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

Methods inherited from interface ConnectionStatus

propagate, propagate, propagate

Constructor Details

DefaultConnectionStatus

public DefaultConnectionStatus(C connection,
 ConnectionDefinition definition,
 boolean isNew,
 ConnectionOperations<C> connectionOperations)

DefaultConnectionStatus

public DefaultConnectionStatus(C connection,
 ConnectionDefinition definition,
 boolean isNew,
 ConnectionOperations<C> connectionOperations,
 @Nullable DefaultConnectionStatus.SuppliedConnection suppliedConnection)

Parameters:

connection - The connection

definition - The connection definition

isNew - Whether the connection was opened for this status

connectionOperations - The connection operations

suppliedConnection - The state of a connection the caller supplied, shared by every status of that connection, see ConnectionOperations.executeWithConnection(Object, ConnectionDefinition, java.util.function.Function)

Since:

5.3.0

Method Details

isSupplied

public boolean isSupplied()

Returns:

Whether the caller supplied the connection, so transactions around it do not apply to it

Since:

5.3.0

getSuppliedConnection

public @Nullable DefaultConnectionStatus.SuppliedConnection getSuppliedConnection()

Returns:

The state of the connection the caller supplied, or null for a connection these operations opened

Since:

5.3.0

isConnectionOf

public boolean isConnectionOf(ConnectionOperations<C> connectionOperations)

isNew

public boolean isNew()

Description copied from interface: ConnectionStatus

A new connection value. Based on the propagation value the connection manager might decide to reuse the existing connection.

Specified by:

isNew in interface ConnectionStatus<C>

Returns:

true if the connection is new

getConnection

public C getConnection()

Description copied from interface: ConnectionStatus

The connection representation.

Specified by:

getConnection in interface ConnectionStatus<C>

Returns:

The connection representation

getDefinition

public ConnectionDefinition getDefinition()

Description copied from interface: ConnectionStatus

The connection definition.

Specified by:

getDefinition in interface ConnectionStatus<C>

Returns:

The connection definition

registerSynchronization

public void registerSynchronization(ConnectionSynchronization synchronization)

Description copied from interface: ConnectionStatus

Register connection synchronization.

Specified by:

registerSynchronization in interface ConnectionStatus<C>

Parameters:

synchronization - The synchronization

complete

public void complete()

beforeClosed

public void beforeClosed()

afterClosed

public void afterClosed()