Package 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	Description
static MongoDbChangeStreamMessageProducerSpec	changeStreamInboundChannelAdapter(ReactiveMongoOperations mongoOperations)	Create a MongoDbChangeStreamMessageProducerSpec builder instance based on the provided ReactiveMongoOperations.
static MongoDbMessageSourceSpec	inboundChannelAdapter(MongoOperations mongoTemplate, String query)	Create a MongoDbMessageSourceSpec builder instance based on the provided MongoOperations.
static MongoDbMessageSourceSpec	inboundChannelAdapter(MongoDatabaseFactory mongoDbFactory, String query)	Create a MongoDbMessageSourceSpec builder instance based on the provided MongoDatabaseFactory.
static MongoDbMessageSourceSpec	inboundChannelAdapter(MongoDatabaseFactory mongoDbFactory, Query query)	Create a MongoDbMessageSourceSpec builder instance based on the provided MongoDatabaseFactory.
static MongoDbOutboundGatewaySpec	outboundGateway(MongoOperations mongoTemplate)	Create a MongoDbOutboundGatewaySpec builder instance based on the provided MongoOperations.
static MongoDbOutboundGatewaySpec	outboundGateway(MongoDatabaseFactory mongoDbFactory, MongoConverter mongoConverter)	Create a MongoDbOutboundGatewaySpec builder instance based on the provided MongoDatabaseFactory and MongoConverter.
static MongoDbMessageSourceSpec	reactiveInboundChannelAdapter(MongoOperations mongoTemplate, Query query)	Create a MongoDbMessageSourceSpec builder instance based on the provided MongoOperations.
static ReactiveMongoDbMessageSourceSpec	reactiveInboundChannelAdapter(ReactiveMongoOperations mongoTemplate, String query)	Create a ReactiveMongoDbMessageSourceSpec builder instance based on the provided ReactiveMongoOperations.
static ReactiveMongoDbMessageSourceSpec	reactiveInboundChannelAdapter(ReactiveMongoOperations mongoTemplate, Query query)	Create a ReactiveMongoDbMessageSourceSpec builder instance based on the provided ReactiveMongoOperations.
static ReactiveMongoDbMessageSourceSpec	reactiveInboundChannelAdapter(ReactiveMongoDatabaseFactory mongoDbFactory, String query)	Create a ReactiveMongoDbMessageSourceSpec builder instance based on the provided ReactiveMongoDatabaseFactory.
static ReactiveMongoDbMessageSourceSpec	reactiveInboundChannelAdapter(ReactiveMongoDatabaseFactory mongoDbFactory, Query query)	Create a ReactiveMongoDbMessageSourceSpec builder instance based on the provided ReactiveMongoDatabaseFactory.
static ReactiveMongoDbMessageHandlerSpec	reactiveOutboundChannelAdapter(ReactiveMongoOperations mongoTemplate)	Create a ReactiveMongoDbMessageHandlerSpec builder instance based on the provided ReactiveMongoOperations.
static ReactiveMongoDbMessageHandlerSpec	reactiveOutboundChannelAdapter(ReactiveMongoDatabaseFactory mongoDbFactory)	Create a ReactiveMongoDbMessageHandlerSpec builder instance based on the provided ReactiveMongoDatabaseFactory.

Methods inherited from class java.lang.Object

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

Method Details

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

inboundChannelAdapter

public static MongoDbMessageSourceSpec inboundChannelAdapter(MongoDatabaseFactory mongoDbFactory, String query)

Create a MongoDbMessageSourceSpec builder instance based on the provided MongoDatabaseFactory.

Parameters:

mongoDbFactory - the MongoDatabaseFactory to use.

query - the MongoDb query

Returns:

the MongoDbMessageSourceSpec instance

Since:

5.5

inboundChannelAdapter

public static MongoDbMessageSourceSpec inboundChannelAdapter(MongoDatabaseFactory mongoDbFactory, Query query)

Create a MongoDbMessageSourceSpec builder instance based on the provided MongoDatabaseFactory.

Parameters:

mongoDbFactory - the MongoDatabaseFactory to use.

query - the MongoDb query DSL object

Returns:

the MongoDbMessageSourceSpec instance

Since:

5.5

inboundChannelAdapter

public static MongoDbMessageSourceSpec inboundChannelAdapter(MongoOperations mongoTemplate, String query)

Create a MongoDbMessageSourceSpec builder instance based on the provided MongoOperations.

Parameters:

mongoTemplate - the MongoOperations to use.

query - the MongoDb query

Returns:

the MongoDbMessageSourceSpec instance

Since:

5.5

reactiveInboundChannelAdapter

public static MongoDbMessageSourceSpec reactiveInboundChannelAdapter(MongoOperations mongoTemplate, Query query)

Create a MongoDbMessageSourceSpec builder instance based on the provided MongoOperations.

Parameters:

mongoTemplate - the MongoOperations to use.

query - the MongoDb query DSL object

Returns:

the MongoDbMessageSourceSpec instance

Since:

5.5