Package org.springframework.data.cassandra.observability

Class ObservableReactiveSessionFactoryBean

java.lang.Object

org.springframework.beans.factory.config.AbstractFactoryBean<ReactiveSession>

org.springframework.data.cassandra.observability.ObservableReactiveSessionFactoryBean

All Implemented Interfaces:

Aware, BeanClassLoaderAware, BeanFactoryAware, DisposableBean, FactoryBean<ReactiveSession>, InitializingBean

public class ObservableReactiveSessionFactoryBean
extends AbstractFactoryBean<ReactiveSession>

Factory bean to construct a ReactiveSession integrated with given ObservationRegistry. The required CqlSession must be associated with ObservationRequestTracker.INSTANCE to ensure proper integration with all observability components. You can use ObservableCqlSessionFactoryBean to obtain a properly configured CqlSession.

Since:

4.0

Author:

Mark Paluch

See Also:

• ObservationRequestTracker
• ObservableReactiveSessionFactory

Field Summary

Fields inherited from class org.springframework.beans.factory.config.AbstractFactoryBean

logger

Fields inherited from interface org.springframework.beans.factory.FactoryBean

OBJECT_TYPE_ATTRIBUTE

Constructor Summary

Constructors

Constructor	Description
ObservableReactiveSessionFactoryBean(com.datastax.oss.driver.api.core.CqlSessionBuilder cqlSessionBuilder, io.micrometer.observation.ObservationRegistry observationRegistry)	Construct a new ObservableReactiveSessionFactoryBean.
ObservableReactiveSessionFactoryBean(com.datastax.oss.driver.api.core.CqlSession cqlSession, io.micrometer.observation.ObservationRegistry observationRegistry)	Construct a new ObservableReactiveSessionFactoryBean.

Method Summary

Modifier and Type	Method	Description
protected ReactiveSession	createInstance()
void	destroy()
Class<?>	getObjectType()
String	getRemoteServiceName()
void	setRemoteServiceName(String remoteServiceName)	Set the remote service name.

Methods inherited from class org.springframework.beans.factory.config.AbstractFactoryBean

afterPropertiesSet, destroyInstance, getBeanFactory, getBeanTypeConverter, getEarlySingletonInterfaces, getObject, isSingleton, setBeanClassLoader, setBeanFactory, setSingleton

Methods inherited from class java.lang.Object

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

Constructor Details

ObservableReactiveSessionFactoryBean

public ObservableReactiveSessionFactoryBean(com.datastax.oss.driver.api.core.CqlSessionBuilder cqlSessionBuilder,
 io.micrometer.observation.ObservationRegistry observationRegistry)

Construct a new ObservableReactiveSessionFactoryBean.

Parameters:

cqlSessionBuilder - must not be null.

observationRegistry - must not be null.

Since:

4.0.5

ObservableReactiveSessionFactoryBean

public ObservableReactiveSessionFactoryBean(com.datastax.oss.driver.api.core.CqlSession cqlSession,
 io.micrometer.observation.ObservationRegistry observationRegistry)

Construct a new ObservableReactiveSessionFactoryBean.

Parameters:

cqlSession - must not be null.

observationRegistry - must not be null.

Method Details

createInstance

protected ReactiveSession createInstance()

Specified by:

createInstance in class AbstractFactoryBean<ReactiveSession>

getObjectType

public Class<?> getObjectType()

Specified by:

getObjectType in interface FactoryBean<ReactiveSession>

Specified by:

getObjectType in class AbstractFactoryBean<ReactiveSession>

getRemoteServiceName

@Nullable
public String getRemoteServiceName()

destroy

public void destroy()

Specified by:

destroy in interface DisposableBean

Overrides:

destroy in class AbstractFactoryBean<ReactiveSession>

setRemoteServiceName

public void setRemoteServiceName(@Nullable
 String remoteServiceName)

Set the remote service name.

Parameters:

remoteServiceName -