spring-integration-core/org.springframework.integration.dsl/KotlinConsumerEndpointSpec

KotlinConsumerEndpointSpec

abstract class KotlinConsumerEndpointSpec<S : ConsumerEndpointSpec<S, H>, H : MessageHandler>(val delegate: S)

A ConsumerEndpointSpec wrapped for Kotlin DSL.

Author

Artem Bilan

Since

5.5.19

Inheritors

Constructors

Link copied to clipboard
constructor(delegate: S)

Properties

Link copied to clipboard
open val delegate: S

the ConsumerEndpointSpec this instance is delegating to.

Functions

Link copied to clipboard
fun advice(vararg advice: Advice?)
Link copied to clipboard
fun autoStartup(autoStartup: Boolean)
Link copied to clipboard
fun <T, V> customizeMonoReply(replyCustomizer: (Message<*>, Mono<T>) -> Publisher<V>)
Link copied to clipboard
fun handleMessageAdvice(vararg interceptors: MethodInterceptor?)
Link copied to clipboard
fun id(id: String?)
Link copied to clipboard
fun phase(phase: Int)
Link copied to clipboard
fun poller(pollers: (PollerFactory) -> PollerSpec)
fun poller(pollerMetadataSpec: PollerSpec)
fun poller(pollerMetadata: PollerMetadata)
Link copied to clipboard
fun reactive()
fun reactive(reactiveCustomizer: (Flux<Message<*>>) -> Publisher<Message<*>>)
Link copied to clipboard
fun role(role: String)
Link copied to clipboard
fun taskScheduler(taskScheduler: TaskScheduler)
Link copied to clipboard
fun transactional()
fun transactional(handleMessageAdvice: Boolean)
fun transactional(transactionManager: TransactionManager)
fun transactional(transactionInterceptor: TransactionInterceptor)
fun transactional(transactionManager: TransactionManager, handleMessageAdvice: Boolean)