KotlinConsumerEndpointSpec

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

A ConsumerEndpointSpec wrapped for Kotlin DSL.

Author

Artem Bilan

Since

5.5.19

Constructors

KotlinConsumerEndpointSpec

fun <S : ConsumerEndpointSpec<S, H>> KotlinConsumerEndpointSpec(delegate: S)

Functions

_this

fun _this(): S

advice

open override fun advice(vararg advice: Advice?): S

afterPropertiesSet

open override fun afterPropertiesSet()

assertHandler

open fun assertHandler()

async

open fun async(async: Boolean): S

autoStartup

open override fun autoStartup(autoStartup: Boolean): S

createInstance

open override fun createInstance(): Tuple2<ConsumerEndpointFactoryBean, H>

customizeMonoReply

open fun <T : Any, V : Any> customizeMonoReply(replyCustomizer: BiFunction<Message<*>, Mono<T>, Publisher<V>>): S

fun <T, V> customizeMonoReply(replyCustomizer: (Message<*>, Mono<T>) -> Publisher<V>)

destroy

open override fun destroy()

destroyInstance

open override fun destroyInstance(instance: Tuple2<ConsumerEndpointFactoryBean, H>)

doGet

open override fun doGet(): Tuple2<ConsumerEndpointFactoryBean, H>

get

open fun get(): Tuple2<ConsumerEndpointFactoryBean, H>

getBeanFactory

@Nullable

open fun getBeanFactory(): BeanFactory

getBeanTypeConverter

open fun getBeanTypeConverter(): TypeConverter

getComponentsToRegister

open override fun getComponentsToRegister(): MutableMap<Any, String>

getEarlySingletonInterfaces

@Nullable

open fun getEarlySingletonInterfaces(): Array<Class<*>>

getId

fun getId(): String

getObject

override fun getObject(): Tuple2<ConsumerEndpointFactoryBean, H>

getObjectType

open override fun getObjectType(): Class<*>

getPhase

open override fun getPhase(): Int

handleMessageAdvice

open override fun handleMessageAdvice(vararg interceptors: MethodInterceptor?): S

open override fun id(id: String?): S

isAutoStartup

open override fun isAutoStartup(): Boolean

isRunning

open override fun isRunning(): Boolean

isSingleton

open override fun isSingleton(): Boolean

notPropagatedHeaders

open fun notPropagatedHeaders(vararg headerPatterns: String): S

obtainInputChannelFromFlow

open fun obtainInputChannelFromFlow(subFlow: IntegrationFlow): MessageChannel

open fun obtainInputChannelFromFlow(subFlow: IntegrationFlow, evaluateInternalBuilder: Boolean): MessageChannel

order

open fun order(order: Int): S

phase

open override fun phase(phase: Int): S

poller

open fun poller(pollers: Function<PollerFactory, PollerSpec>): S

fun poller(pollers: (PollerFactory) -> PollerSpec)

open override fun poller(pollerMetadataSpec: PollerSpec): S

open override fun poller(pollerMetadata: PollerMetadata): S

reactive

open override fun reactive(): S

open fun reactive(reactiveCustomizer: Function<in Flux<Message<*>>, out Publisher<Message<*>>>): S

fun reactive(reactiveCustomizer: (Flux<Message<*>>) -> Publisher<Message<*>>)

requiresReply

open fun requiresReply(requiresReply: Boolean): S

role

open override fun role(role: String): S

sendTimeout

open fun sendTimeout(sendTimeout: Long): S

setBeanClassLoader

open override fun setBeanClassLoader(p0: ClassLoader)

setBeanFactory

open override fun setBeanFactory(@Nullable p0: BeanFactory)

setSingleton

open fun setSingleton(p0: Boolean)

start

open override fun start()

stop

open override fun stop()

open override fun stop(callback: Runnable)

taskScheduler

open override fun taskScheduler(taskScheduler: TaskScheduler): S

transactional

open override fun transactional(): S

open override fun transactional(handleMessageAdvice: Boolean): S

open override fun transactional(transactionManager: TransactionManager): S

open override fun transactional(transactionInterceptor: TransactionInterceptor): S

open override fun transactional(transactionManager: TransactionManager, handleMessageAdvice: Boolean): S

Properties

adviceChain

val adviceChain: MutableList<Advice>

componentsToRegister

val componentsToRegister: MutableMap<Any, String>

delegate

open val delegate: S

the ConsumerEndpointSpec this instance is delegating to.

endpointFactoryBean

val endpointFactoryBean: ConsumerEndpointFactoryBean

handler

val handler: H

logger

val logger: Log

target

val target: Tuple2<ConsumerEndpointFactoryBean, H>

Inheritors

AbstractKotlinRouterSpec

KotlinEnricherSpec

KotlinFilterEndpointSpec

KotlinSplitterEndpointSpec