Package org.springframework.data.cassandra.observability

Class ObservableReactiveSessionFactory

java.lang.Object

org.springframework.data.cassandra.observability.ObservableReactiveSessionFactory

public final class ObservableReactiveSessionFactory
extends Object

Factory to wrap a ReactiveSession with ObservableReactiveSession.

Since:

4.0

Author:

Mark Paluch

Method Summary

Modifier and Type	Method	Description
static ReactiveSession	wrap(ReactiveSession session, io.micrometer.observation.ObservationRegistry observationRegistry)	Wrap the CqlSession with a CqlSessionObservationInterceptor.
static ReactiveSession	wrap(ReactiveSession session, String remoteServiceName, io.micrometer.observation.ObservationRegistry observationRegistry)	Wrap the CqlSession with a CqlSessionObservationInterceptor.

Methods inherited from class java.lang.Object

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

Method Details

wrap

public static ReactiveSession wrap(ReactiveSession session,
 io.micrometer.observation.ObservationRegistry observationRegistry)

Wrap the CqlSession with a CqlSessionObservationInterceptor.

Parameters:

session - must not be null.

observationRegistry - must not be null.

Returns:

wrap

public static ReactiveSession wrap(ReactiveSession session,
 String remoteServiceName,
 io.micrometer.observation.ObservationRegistry observationRegistry)

Wrap the CqlSession with a CqlSessionObservationInterceptor.

Parameters:

session - must not be null.

remoteServiceName - must not be null.

observationRegistry - must not be null.

Returns: