public class R2dbcMessageSourceSpec extends org.springframework.integration.dsl.MessageSourceSpec<R2dbcMessageSourceSpec,R2dbcMessageSource>
MessageSourceSpec for the R2dbcMessageSource.| Modifier | Constructor and Description |
|---|---|
protected |
R2dbcMessageSourceSpec(org.springframework.data.r2dbc.core.R2dbcEntityOperations r2dbcEntityOperations,
org.springframework.expression.Expression queryExpression) |
protected |
R2dbcMessageSourceSpec(org.springframework.data.r2dbc.core.R2dbcEntityOperations r2dbcEntityOperations,
java.lang.String query) |
| Modifier and Type | Method and Description |
|---|---|
R2dbcMessageSourceSpec |
bindFunction(java.util.function.BiFunction<org.springframework.r2dbc.core.DatabaseClient.GenericExecuteSpec,?,org.springframework.r2dbc.core.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(java.lang.Class<?> payloadType)
Set the expected payload type.
|
R2dbcMessageSourceSpec |
updateSql(java.lang.String updateSql)
Configure an update query.
|
_this, createInstance, destroyInstance, doGet, get, getId, getObjectType, getPhase, id, isAutoStartup, isRunning, start, stop, stopprotected R2dbcMessageSourceSpec(org.springframework.data.r2dbc.core.R2dbcEntityOperations r2dbcEntityOperations,
java.lang.String query)
protected R2dbcMessageSourceSpec(org.springframework.data.r2dbc.core.R2dbcEntityOperations r2dbcEntityOperations,
org.springframework.expression.Expression queryExpression)
public R2dbcMessageSourceSpec payloadType(java.lang.Class<?> payloadType)
payloadType - the class to use.public R2dbcMessageSourceSpec updateSql(java.lang.String updateSql)
updateSql - the update query string.public R2dbcMessageSourceSpec bindFunction(java.util.function.BiFunction<org.springframework.r2dbc.core.DatabaseClient.GenericExecuteSpec,?,org.springframework.r2dbc.core.DatabaseClient.GenericExecuteSpec> bindFunction)
BiFunction which is used to bind parameters into the update query.bindFunction - the BiFunction to use.public R2dbcMessageSourceSpec expectSingleResult(boolean expectSingleResult)
R2dbcEntityOperations.expectSingleResult - true if a single result is expected.