io.r2dbc.proxy.listener

Interface ProxyExecutionListener

All Known Subinterfaces:

ProxyMethodExecutionListener

All Known Implementing Classes:

CompositeProxyExecutionListener, LastExecutionAwareListener, ObservationProxyExecutionListener, ProxyMethodExecutionListenerAdapter

public interface ProxyExecutionListener

Listener interface that is called when proxy is invoked.

Author:

Tadaya Tsuyukubo

Method Summary

Modifier and Type	Method and Description
default void	afterMethod(MethodExecutionInfo executionInfo) Called after every invocation of methods.
default void	afterQuery(QueryExecutionInfo execInfo) Called after executing a query (Batch.execute() or Statement.execute()).
default void	beforeMethod(MethodExecutionInfo executionInfo) Called before every invocation of methods.
default void	beforeQuery(QueryExecutionInfo execInfo) Called before executing a query (Batch.execute() or Statement.execute()).
default void	eachQueryResult(QueryExecutionInfo execInfo) Called on processing each query Result.

Method Detail

beforeMethod

default void beforeMethod(MethodExecutionInfo executionInfo)

Called before every invocation of methods.

Exception Handling: Exceptions thrown by this method are dropped and do not affect the original subscription's publisher flow. Such exceptions are reported to Hooks.onErrorDropped(java.util.function.Consumer).

Parameters:

executionInfo - method execution context

afterMethod

default void afterMethod(MethodExecutionInfo executionInfo)

Called after every invocation of methods.

Exception Handling: Exceptions thrown by this method are dropped and do not affect the original subscription's publisher flow. Such exceptions are reported to Hooks.onErrorDropped(java.util.function.Consumer).

Parameters:

executionInfo - method execution context

beforeQuery

default void beforeQuery(QueryExecutionInfo execInfo)

Called before executing a query (Batch.execute() or Statement.execute()).

Note: this callback is called when the publisher, result of the execute(), is being subscribed. Not at the time of execute() is called,

Exception Handling: Exceptions thrown by this method are dropped and do not affect the original subscription's publisher flow. Such exceptions are reported to Hooks.onErrorDropped(java.util.function.Consumer).

Parameters:

execInfo - query execution context

afterQuery

default void afterQuery(QueryExecutionInfo execInfo)

Called after executing a query (Batch.execute() or Statement.execute()).

The callback order is:

• beforeQuery(QueryExecutionInfo)
• eachQueryResult(QueryExecutionInfo) for 1st result
• eachQueryResult(QueryExecutionInfo) for 2nd result
• ...
• eachQueryResult(QueryExecutionInfo) for Nth result
• afterQuery(QueryExecutionInfo)

QueryExecutionInfo.getExecuteDuration() is available in this callback and it holds the duration since beforeQuery(QueryExecutionInfo).

Note: this callback is called when the publisher, result of the execute(), is being subscribed. Not at the time of execute() is called,

Exception Handling: Exceptions thrown by this method are dropped and do not affect the original subscription's publisher flow. Such exceptions are reported to Hooks.onErrorDropped(java.util.function.Consumer).

Parameters:

execInfo - query execution context

eachQueryResult

default void eachQueryResult(QueryExecutionInfo execInfo)

Called on processing each query Result.

While processing query results Result, this callback is called per result.

QueryExecutionInfo.getCurrentMappedResult() contains the mapped result.

Exception Handling: Exceptions thrown by this method are dropped and do not affect the original subscription's publisher flow. Such exceptions are reported to Hooks.onErrorDropped(java.util.function.Consumer).

Parameters:

execInfo - query execution context