org.springframework.cloud.stream.app.mongodb.source

Class MongodbSourceConfiguration

java.lang.Object

org.springframework.cloud.stream.app.mongodb.source.MongodbSourceConfiguration

@EnableBinding(value=org.springframework.cloud.stream.messaging.Source.class)
 @EnableConfigurationProperties(value={MongodbSourceProperties.class,TriggerPropertiesMaxMessagesDefaultUnlimited.class})
 @Import(value=TriggerConfiguration.class)
public class MongodbSourceConfiguration
extends Object

A starter configuration for MongoDB Source applications. Produces MongoDbMessageSource which polls collection with the query after startup according to the polling properties.

Author:

Adam Zwickey, Artem Bilan

Constructor Summary

Constructors

Constructor and Description
MongodbSourceConfiguration()

Method Summary

Modifier and Type	Method and Description
protected org.springframework.integration.mongodb.inbound.MongoDbMessageSource	mongoSource() The inheritors can consider to override this method for their purpose or just adjust options for the returned instance
org.springframework.integration.dsl.IntegrationFlow	startFlow()

Methods inherited from class java.lang.Object

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

Constructor Detail

MongodbSourceConfiguration

public MongodbSourceConfiguration()

Method Detail

startFlow

@Bean
public org.springframework.integration.dsl.IntegrationFlow startFlow()
                                                                    throws Exception

Throws:

Exception

mongoSource

protected org.springframework.integration.mongodb.inbound.MongoDbMessageSource mongoSource()

The inheritors can consider to override this method for their purpose or just adjust options for the returned instance

Returns:

a MongoDbMessageSource instance