Package org.springframework.integration.mongodb.dsl

Class ReactiveMongoDbMessageSourceSpec

java.lang.Object

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

org.springframework.integration.dsl.IntegrationComponentSpec<S,H>

org.springframework.integration.dsl.MessageSourceSpec<ReactiveMongoDbMessageSourceSpec,ReactiveMongoDbMessageSource>

org.springframework.integration.mongodb.dsl.ReactiveMongoDbMessageSourceSpec

All Implemented Interfaces:

Aware, BeanClassLoaderAware, BeanFactoryAware, DisposableBean, FactoryBean<ReactiveMongoDbMessageSource>, InitializingBean, Lifecycle, Phased, SmartLifecycle

public class ReactiveMongoDbMessageSourceSpec
extends MessageSourceSpec<ReactiveMongoDbMessageSourceSpec,ReactiveMongoDbMessageSource>

A MessageSourceSpec implementation for a ReactiveMongoDbMessageSource.

Since:

5.3

Author:

Artem Bilan

Field Summary

Fields inherited from class org.springframework.integration.dsl.IntegrationComponentSpec

PARSER, target

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

logger

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

OBJECT_TYPE_ATTRIBUTE

Fields inherited from interface org.springframework.context.SmartLifecycle

DEFAULT_PHASE

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	ReactiveMongoDbMessageSourceSpec(ReactiveMongoOperations reactiveMongoTemplate, Expression queryExpression)
protected	ReactiveMongoDbMessageSourceSpec(ReactiveMongoDatabaseFactory reactiveMongoDatabaseFactory, Expression queryExpression)

Method Summary

Modifier and Type	Method	Description
ReactiveMongoDbMessageSourceSpec	collectionName(String collectionName)	Configure a collection name to query against.
ReactiveMongoDbMessageSourceSpec	collectionNameExpression(String collectionNameExpression)	Configure a SpEL expression to evaluation a collection name on each receive() call.
ReactiveMongoDbMessageSourceSpec	collectionNameExpression(Expression collectionNameExpression)	Configure a SpEL expression to evaluation a collection name on each receive() call.
ReactiveMongoDbMessageSourceSpec	collectionNameSupplier(Supplier<String> collectionNameSupplier)	Configure a Supplier to obtain a collection name on each receive() call.
ReactiveMongoDbMessageSourceSpec	entityClass(Class<?> entityClass)	Allow you to set the type of the entityClass that will be passed to the ReactiveMongoOperations.find(org.springframework.data.mongodb.core.query.Query, java.lang.Class<T>) or ReactiveMongoOperations.findOne(org.springframework.data.mongodb.core.query.Query, java.lang.Class<T>) method.
ReactiveMongoDbMessageSourceSpec	expectSingleResult(boolean expectSingleResult)	Allow you to manage which find* method to invoke on ReactiveMongoOperations.
ReactiveMongoDbMessageSourceSpec	mongoConverter(MongoConverter mongoConverter)	Configure a custom MongoConverter used to assist in deserialization data read from MongoDb.

Methods inherited from class org.springframework.integration.dsl.MessageSourceSpec

messageHeaders

Methods inherited from class org.springframework.integration.dsl.IntegrationComponentSpec

_this, createInstance, destroyInstance, doGet, get, getId, getObjectType, getPhase, id, isAutoStartup, isRunning, start, stop, stop

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

ReactiveMongoDbMessageSourceSpec

protected ReactiveMongoDbMessageSourceSpec(ReactiveMongoDatabaseFactory reactiveMongoDatabaseFactory, Expression queryExpression)

ReactiveMongoDbMessageSourceSpec

protected ReactiveMongoDbMessageSourceSpec(ReactiveMongoOperations reactiveMongoTemplate, Expression queryExpression)

Method Details

entityClass

public ReactiveMongoDbMessageSourceSpec entityClass(Class<?> entityClass)

Allow you to set the type of the entityClass that will be passed to the ReactiveMongoOperations.find(org.springframework.data.mongodb.core.query.Query, java.lang.Class<T>) or ReactiveMongoOperations.findOne(org.springframework.data.mongodb.core.query.Query, java.lang.Class<T>) method. Default is DBObject.

Parameters:

entityClass - The entity class.

Returns:

the spec

See Also:

ReactiveMongoDbMessageSource.setEntityClass(Class)

expectSingleResult

public ReactiveMongoDbMessageSourceSpec expectSingleResult(boolean expectSingleResult)

Allow you to manage which find* method to invoke on ReactiveMongoOperations.

Parameters:

expectSingleResult - true if a single result is expected.

Returns:

the spec

See Also:

ReactiveMongoDbMessageSource.setExpectSingleResult(boolean)

collectionName

public ReactiveMongoDbMessageSourceSpec collectionName(String collectionName)

Configure a collection name to query against.

Parameters:

collectionName - the name of the MongoDb collection

Returns:

the spec

collectionNameExpression

public ReactiveMongoDbMessageSourceSpec collectionNameExpression(String collectionNameExpression)

Configure a SpEL expression to evaluation a collection name on each receive() call.

Parameters:

collectionNameExpression - the SpEL expression for name of the MongoDb collection

Returns:

the spec

collectionNameSupplier

public ReactiveMongoDbMessageSourceSpec collectionNameSupplier(Supplier<String> collectionNameSupplier)

Configure a Supplier to obtain a collection name on each receive() call.

Parameters:

collectionNameSupplier - the Supplier for name of the MongoDb collection

Returns:

the spec

collectionNameExpression

public ReactiveMongoDbMessageSourceSpec collectionNameExpression(Expression collectionNameExpression)

Configure a SpEL expression to evaluation a collection name on each receive() call.

Parameters:

collectionNameExpression - the SpEL expression for name of the MongoDb collection

Returns:

the spec

See Also:

ReactiveMongoDbMessageSource.setCollectionNameExpression(Expression)

mongoConverter

public ReactiveMongoDbMessageSourceSpec mongoConverter(MongoConverter mongoConverter)

Configure a custom MongoConverter used to assist in deserialization data read from MongoDb. Only allowed if this instance was constructed with a ReactiveMongoDatabaseFactory.

Parameters:

mongoConverter - The mongo converter.

Returns:

the spec

See Also:

ReactiveMongoDbMessageSource.setMongoConverter(MongoConverter)