Package org.springframework.data.mongodb.core

Class ReactiveMongoClientFactoryBean

java.lang.Object

org.springframework.beans.factory.config.AbstractFactoryBean<com.mongodb.reactivestreams.client.MongoClient>

org.springframework.data.mongodb.core.ReactiveMongoClientFactoryBean

All Implemented Interfaces:

Aware, BeanClassLoaderAware, BeanFactoryAware, DisposableBean, FactoryBean<com.mongodb.reactivestreams.client.MongoClient>, InitializingBean, PersistenceExceptionTranslator

public class ReactiveMongoClientFactoryBean
extends AbstractFactoryBean<com.mongodb.reactivestreams.client.MongoClient>
implements PersistenceExceptionTranslator

Convenient factory for configuring a reactive streams MongoClient.

Since:

2.0

Author:

Mark Paluch, Christoph Strobl

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
ReactiveMongoClientFactoryBean()

Method Summary

Modifier and Type	Method	Description
protected com.mongodb.reactivestreams.client.MongoClient	createInstance()
protected void	destroyInstance(com.mongodb.reactivestreams.client.MongoClient instance)
Class<?>	getObjectType()
void	setConnectionString(String connectionString)	Configures the connection string.
void	setExceptionTranslator(PersistenceExceptionTranslator exceptionTranslator)	Configures the PersistenceExceptionTranslator to use.
void	setHost(String host)	Configures the host to connect to.
void	setMongoClientSettings(com.mongodb.MongoClientSettings mongoClientSettings)	Configures the mongo client settings.
void	setPort(int port)	Configures the port to connect to.
DataAccessException	translateExceptionIfPossible(RuntimeException ex)

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

afterPropertiesSet, destroy, 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

ReactiveMongoClientFactoryBean

public ReactiveMongoClientFactoryBean()

Method Details

setHost

public void setHost(@Nullable
 String host)

Configures the host to connect to.

Parameters:

host -

setPort

public void setPort(int port)

Configures the port to connect to.

Parameters:

port -

setConnectionString

public void setConnectionString(@Nullable
 String connectionString)

Configures the connection string.

Parameters:

connectionString -

setMongoClientSettings

public void setMongoClientSettings(@Nullable
 com.mongodb.MongoClientSettings mongoClientSettings)

Configures the mongo client settings.

Parameters:

mongoClientSettings -

setExceptionTranslator

public void setExceptionTranslator(@Nullable
 PersistenceExceptionTranslator exceptionTranslator)

Configures the PersistenceExceptionTranslator to use.

Parameters:

exceptionTranslator -

getObjectType

public Class<?> getObjectType()

Specified by:

getObjectType in interface FactoryBean<com.mongodb.reactivestreams.client.MongoClient>

Specified by:

getObjectType in class AbstractFactoryBean<com.mongodb.reactivestreams.client.MongoClient>

createInstance

protected com.mongodb.reactivestreams.client.MongoClient createInstance()
                                                                 throws Exception

Specified by:

createInstance in class AbstractFactoryBean<com.mongodb.reactivestreams.client.MongoClient>

Throws:

Exception

destroyInstance

protected void destroyInstance(@Nullable
 com.mongodb.reactivestreams.client.MongoClient instance)
                        throws Exception

Overrides:

destroyInstance in class AbstractFactoryBean<com.mongodb.reactivestreams.client.MongoClient>

Throws:

Exception

translateExceptionIfPossible

public DataAccessException translateExceptionIfPossible(RuntimeException ex)

Specified by:

translateExceptionIfPossible in interface PersistenceExceptionTranslator