Package org.springframework.integration.r2dbc.dsl

Class R2dbcMessageSourceSpec

java.lang.Object

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

org.springframework.integration.dsl.MessageSourceSpec<R2dbcMessageSourceSpec,R2dbcMessageSource>

org.springframework.integration.r2dbc.dsl.R2dbcMessageSourceSpec

All Implemented Interfaces:

DisposableBean, FactoryBean<R2dbcMessageSource>, InitializingBean, Lifecycle, Phased, SmartLifecycle

public class R2dbcMessageSourceSpec
extends MessageSourceSpec<R2dbcMessageSourceSpec,R2dbcMessageSource>

The MessageSourceSpec for the R2dbcMessageSource.

Since:

5.4

Author:

Artem Bilan

Field Summary

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

logger, PARSER, target

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	R2dbcMessageSourceSpec(org.springframework.data.r2dbc.core.R2dbcEntityOperations r2dbcEntityOperations, String query)
protected	R2dbcMessageSourceSpec(org.springframework.data.r2dbc.core.R2dbcEntityOperations r2dbcEntityOperations, Expression queryExpression)

Method Summary

Modifier and Type	Method	Description
R2dbcMessageSourceSpec	bindFunction(BiFunction<DatabaseClient.GenericExecuteSpec,?,DatabaseClient.GenericExecuteSpec> bindFunction)	Set a BiFunction which is used to bind parameters into the update query.
R2dbcMessageSourceSpec	expectSingleResult(boolean expectSingleResult)	The flag to manage which find* method to invoke on R2dbcEntityOperations.
R2dbcMessageSourceSpec	payloadType(Class<?> payloadType)	Set the expected payload type.
R2dbcMessageSourceSpec	updateSql(String updateSql)	Configure an update query.

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

messageHeaders

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

_this, afterPropertiesSet, destroy, doGet, get, getId, getObject, getObjectType, getPhase, id, isAutoStartup, isRunning, start, stop, stop

Methods inherited from class java.lang.Object

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

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

isSingleton

Constructor Details

R2dbcMessageSourceSpec

protected R2dbcMessageSourceSpec(org.springframework.data.r2dbc.core.R2dbcEntityOperations r2dbcEntityOperations,
 String query)

R2dbcMessageSourceSpec

protected R2dbcMessageSourceSpec(org.springframework.data.r2dbc.core.R2dbcEntityOperations r2dbcEntityOperations,
 Expression queryExpression)

Method Details

payloadType

public R2dbcMessageSourceSpec payloadType(Class<?> payloadType)

Set the expected payload type.

Parameters:

payloadType - the class to use.

Returns:

the spec

updateSql

public R2dbcMessageSourceSpec updateSql(String updateSql)

Configure an update query.

Parameters:

updateSql - the update query string.

Returns:

the spec

bindFunction

public R2dbcMessageSourceSpec bindFunction(BiFunction<DatabaseClient.GenericExecuteSpec,?,DatabaseClient.GenericExecuteSpec> bindFunction)

Set a BiFunction which is used to bind parameters into the update query.

Parameters:

bindFunction - the BiFunction to use.

Returns:

the spec

expectSingleResult

public R2dbcMessageSourceSpec expectSingleResult(boolean expectSingleResult)

The flag to manage which find* method to invoke on R2dbcEntityOperations.

Parameters:

expectSingleResult - true if a single result is expected.

Returns:

the spec