org.springframework.integration.mongodb.dsl

Class MongoDb

java.lang.Object

org.springframework.integration.mongodb.dsl.MongoDb

public final class MongoDb
extends Object

Factory class for building MongoDb components

Since:

5.0

Author:

Xavier Padro, Artem Bilan

Method Summary

Modifier and Type	Method and Description
static MongoDbChangeStreamMessageProducerSpec	changeStreamInboundChannelAdapter(ReactiveMongoOperations mongoOperations) Create a MongoDbChangeStreamMessageProducerSpec builder instance based on the provided ReactiveMongoOperations.
static MongoDbOutboundGatewaySpec	outboundGateway(MongoDatabaseFactory mongoDbFactory, MongoConverter mongoConverter) Create a MongoDbOutboundGatewaySpec builder instance based on the provided MongoDatabaseFactory and MongoConverter.
static MongoDbOutboundGatewaySpec	outboundGateway(MongoOperations mongoTemplate) Create a MongoDbOutboundGatewaySpec builder instance based on the provided MongoOperations.
static ReactiveMongoDbMessageSourceSpec	reactiveInboundChannelAdapter(ReactiveMongoDatabaseFactory mongoDbFactory, Query query) Create a ReactiveMongoDbMessageSourceSpec builder instance based on the provided ReactiveMongoDatabaseFactory.
static ReactiveMongoDbMessageSourceSpec	reactiveInboundChannelAdapter(ReactiveMongoDatabaseFactory mongoDbFactory, String query) Create a ReactiveMongoDbMessageSourceSpec builder instance based on the provided ReactiveMongoDatabaseFactory.
static ReactiveMongoDbMessageSourceSpec	reactiveInboundChannelAdapter(ReactiveMongoOperations mongoTemplate, Query query) Create a ReactiveMongoDbMessageSourceSpec builder instance based on the provided ReactiveMongoOperations.
static ReactiveMongoDbMessageSourceSpec	reactiveInboundChannelAdapter(ReactiveMongoOperations mongoTemplate, String query) Create a ReactiveMongoDbMessageSourceSpec builder instance based on the provided ReactiveMongoOperations.
static ReactiveMongoDbMessageHandlerSpec	reactiveOutboundChannelAdapter(ReactiveMongoDatabaseFactory mongoDbFactory) Create a ReactiveMongoDbMessageHandlerSpec builder instance based on the provided ReactiveMongoDatabaseFactory.
static ReactiveMongoDbMessageHandlerSpec	reactiveOutboundChannelAdapter(ReactiveMongoOperations mongoTemplate) Create a ReactiveMongoDbMessageHandlerSpec builder instance based on the provided ReactiveMongoOperations.

Methods inherited from class java.lang.Object

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

Method Detail

outboundGateway

public static MongoDbOutboundGatewaySpec outboundGateway(MongoDatabaseFactory mongoDbFactory,
                                                         MongoConverter mongoConverter)

Create a MongoDbOutboundGatewaySpec builder instance based on the provided MongoDatabaseFactory and MongoConverter.

Parameters:

mongoDbFactory - the MongoDatabaseFactory to use.

mongoConverter - the MongoConverter to use.

Returns:

the MongoDbOutboundGatewaySpec instance

outboundGateway

public static MongoDbOutboundGatewaySpec outboundGateway(MongoOperations mongoTemplate)

Create a MongoDbOutboundGatewaySpec builder instance based on the provided MongoOperations.

Parameters:

mongoTemplate - the MongoOperations to use.

Returns:

the MongoDbOutboundGatewaySpec instance

reactiveOutboundChannelAdapter

public static ReactiveMongoDbMessageHandlerSpec reactiveOutboundChannelAdapter(ReactiveMongoDatabaseFactory mongoDbFactory)

Create a ReactiveMongoDbMessageHandlerSpec builder instance based on the provided ReactiveMongoDatabaseFactory.

Parameters:

mongoDbFactory - the ReactiveMongoDatabaseFactory to use.

Returns:

the MongoDbOutboundGatewaySpec instance

Since:

5.3

reactiveOutboundChannelAdapter

public static ReactiveMongoDbMessageHandlerSpec reactiveOutboundChannelAdapter(ReactiveMongoOperations mongoTemplate)

Create a ReactiveMongoDbMessageHandlerSpec builder instance based on the provided ReactiveMongoOperations.

Parameters:

mongoTemplate - the ReactiveMongoOperations to use.

Returns:

the ReactiveMongoDbMessageHandlerSpec instance

Since:

5.3

reactiveInboundChannelAdapter

public static ReactiveMongoDbMessageSourceSpec reactiveInboundChannelAdapter(ReactiveMongoDatabaseFactory mongoDbFactory,
                                                                             String query)

Create a ReactiveMongoDbMessageSourceSpec builder instance based on the provided ReactiveMongoDatabaseFactory.

Parameters:

mongoDbFactory - the ReactiveMongoDatabaseFactory to use.

query - the MongoDb query

Returns:

the ReactiveMongoDbMessageSourceSpec instance

Since:

5.3

reactiveInboundChannelAdapter

public static ReactiveMongoDbMessageSourceSpec reactiveInboundChannelAdapter(ReactiveMongoDatabaseFactory mongoDbFactory,
                                                                             Query query)

Create a ReactiveMongoDbMessageSourceSpec builder instance based on the provided ReactiveMongoDatabaseFactory.

Parameters:

mongoDbFactory - the ReactiveMongoDatabaseFactory to use.

query - the MongoDb query DSL object

Returns:

the ReactiveMongoDbMessageSourceSpec instance

Since:

5.3

reactiveInboundChannelAdapter

public static ReactiveMongoDbMessageSourceSpec reactiveInboundChannelAdapter(ReactiveMongoOperations mongoTemplate,
                                                                             String query)

Create a ReactiveMongoDbMessageSourceSpec builder instance based on the provided ReactiveMongoOperations.

Parameters:

mongoTemplate - the ReactiveMongoOperations to use.

query - the MongoDb query

Returns:

the ReactiveMongoDbMessageSourceSpec instance

Since:

5.3

reactiveInboundChannelAdapter

public static ReactiveMongoDbMessageSourceSpec reactiveInboundChannelAdapter(ReactiveMongoOperations mongoTemplate,
                                                                             Query query)

Create a ReactiveMongoDbMessageSourceSpec builder instance based on the provided ReactiveMongoOperations.

Parameters:

mongoTemplate - the ReactiveMongoOperations to use.

query - the MongoDb query DSL object

Returns:

the ReactiveMongoDbMessageSourceSpec instance

Since:

5.3

changeStreamInboundChannelAdapter

public static MongoDbChangeStreamMessageProducerSpec changeStreamInboundChannelAdapter(ReactiveMongoOperations mongoOperations)

Create a MongoDbChangeStreamMessageProducerSpec builder instance based on the provided ReactiveMongoOperations.

Parameters:

mongoOperations - the ReactiveMongoOperations to use.

Returns:

the MongoDbChangeStreamMessageProducerSpec instance

Since:

5.3