org.springframework.integration.mongodb.dsl

Class MongoDbChangeStreamMessageProducerSpec

java.lang.Object

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

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

org.springframework.integration.dsl.MessageProducerSpec<MongoDbChangeStreamMessageProducerSpec,MongoDbChangeStreamMessageProducer>

org.springframework.integration.mongodb.dsl.MongoDbChangeStreamMessageProducerSpec

All Implemented Interfaces:

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

public class MongoDbChangeStreamMessageProducerSpec
extends MessageProducerSpec<MongoDbChangeStreamMessageProducerSpec,MongoDbChangeStreamMessageProducer>

A MessageProducerSpec for tne MongoDbChangeStreamMessageProducer.

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.context.SmartLifecycle

DEFAULT_PHASE

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

OBJECT_TYPE_ATTRIBUTE

Constructor Summary

Constructors

Constructor and Description
MongoDbChangeStreamMessageProducerSpec(MongoDbChangeStreamMessageProducer producer) Construct a builder based on an initial MongoDbChangeStreamMessageProducerSpec.

Method Summary

Modifier and Type	Method and Description
MongoDbChangeStreamMessageProducerSpec	collection(String collection) Configure a collection to subscribe for change events.
MongoDbChangeStreamMessageProducerSpec	domainType(Class<?> domainType) Configure a domain type to convert change event body into.
MongoDbChangeStreamMessageProducerSpec	extractBody(boolean extractBody) Configure a flag to extract body from a change event or use event as a payload.
MongoDbChangeStreamMessageProducerSpec	options(ChangeStreamOptions options) Configure a ChangeStreamOptions.

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

autoStartup, errorChannel, errorChannel, errorMessageStrategy, id, outputChannel, outputChannel, phase, sendTimeout, shouldTrack

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

_this, createInstance, destroyInstance, doGet, get, getId, getObjectType, getPhase, 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 Detail

MongoDbChangeStreamMessageProducerSpec

public MongoDbChangeStreamMessageProducerSpec(MongoDbChangeStreamMessageProducer producer)

Construct a builder based on an initial MongoDbChangeStreamMessageProducerSpec.

Parameters:

producer - the MongoDbChangeStreamMessageProducerSpec to use.

Method Detail

domainType

public MongoDbChangeStreamMessageProducerSpec domainType(Class<?> domainType)

Configure a domain type to convert change event body into.

Parameters:

domainType - the type to use.

Returns:

the spec.

collection

public MongoDbChangeStreamMessageProducerSpec collection(String collection)

Configure a collection to subscribe for change events.

Parameters:

collection - the collection to use.

Returns:

the spec.

options

public MongoDbChangeStreamMessageProducerSpec options(ChangeStreamOptions options)

Configure a ChangeStreamOptions.

Parameters:

options - the ChangeStreamOptions to use.

Returns:

the spec.

extractBody

public MongoDbChangeStreamMessageProducerSpec extractBody(boolean extractBody)

Configure a flag to extract body from a change event or use event as a payload.

Parameters:

extractBody - to extract body or not.

Returns:

the spec.