KotlinFilterEndpointSpec

An FilterEndpointSpec wrapped for Kotlin DSL.

Author

Artem Bilan

Since

5.3

Constructors

KotlinFilterEndpointSpec
Link copied to clipboard
fun KotlinFilterEndpointSpec(delegate: FilterEndpointSpec)

Functions

_this
Link copied to clipboard
fun _this(): FilterEndpointSpec
advice
Link copied to clipboard
open fun advice(vararg advice: Advice): FilterEndpointSpec
afterPropertiesSet
Link copied to clipboard
open override fun afterPropertiesSet()
assertHandler
Link copied to clipboard
open fun assertHandler()
async
Link copied to clipboard
open fun async(async: Boolean): FilterEndpointSpec
autoStartup
Link copied to clipboard
open override fun autoStartup(autoStartup: Boolean): FilterEndpointSpec
createInstance
Link copied to clipboard
open override fun createInstance(): Tuple2<ConsumerEndpointFactoryBean, MessageFilter>
customizeMonoReply
Link copied to clipboard
open fun <T : Any, V : Any> customizeMonoReply(replyCustomizer: BiFunction<Message<*>, Mono<T>, Publisher<V>>): FilterEndpointSpec
destroy
Link copied to clipboard
open override fun destroy()
destroyInstance
Link copied to clipboard
open override fun destroyInstance(instance: Tuple2<ConsumerEndpointFactoryBean, MessageFilter>)
discardChannel
Link copied to clipboard
fun discardChannel(discardChannelName: String)
fun discardChannel(discardChannel: MessageChannel)
discardFlow
Link copied to clipboard
fun discardFlow(subFlow: KotlinIntegrationFlowDefinition.() -> Unit)
discardWithinAdvice
Link copied to clipboard
fun discardWithinAdvice(discardWithinAdvice: Boolean)
doGet
Link copied to clipboard
open override fun doGet(): Tuple2<ConsumerEndpointFactoryBean, MessageFilter>
get
Link copied to clipboard
open fun get(): Tuple2<ConsumerEndpointFactoryBean, MessageFilter>
getBeanFactory
Link copied to clipboard
@Nullable
open fun getBeanFactory(): BeanFactory
getBeanTypeConverter
Link copied to clipboard
open fun getBeanTypeConverter(): TypeConverter
getComponentsToRegister
Link copied to clipboard
open override fun getComponentsToRegister(): MutableMap<Any, String>
getEarlySingletonInterfaces
Link copied to clipboard
@Nullable
open fun getEarlySingletonInterfaces(): Array<Class<*>>
getId
Link copied to clipboard
fun getId(): String
getObject
Link copied to clipboard
override fun getObject(): Tuple2<ConsumerEndpointFactoryBean, MessageFilter>
getObjectType
Link copied to clipboard
open override fun getObjectType(): Class<*>
getPhase
Link copied to clipboard
open override fun getPhase(): Int
handleMessageAdvice
Link copied to clipboard
open fun handleMessageAdvice(vararg interceptors: MethodInterceptor): FilterEndpointSpec
id
Link copied to clipboard
open override fun id(id: String): FilterEndpointSpec
isAutoStartup
Link copied to clipboard
open override fun isAutoStartup(): Boolean
isRunning
Link copied to clipboard
open override fun isRunning(): Boolean
isSingleton
Link copied to clipboard
open override fun isSingleton(): Boolean
notPropagatedHeaders
Link copied to clipboard
open fun notPropagatedHeaders(vararg headerPatterns: String): FilterEndpointSpec
obtainInputChannelFromFlow
Link copied to clipboard
open fun obtainInputChannelFromFlow(subFlow: IntegrationFlow): MessageChannel
open fun obtainInputChannelFromFlow(subFlow: IntegrationFlow, evaluateInternalBuilder: Boolean): MessageChannel
order
Link copied to clipboard
open fun order(order: Int): FilterEndpointSpec
phase
Link copied to clipboard
open override fun phase(phase: Int): FilterEndpointSpec
poller
Link copied to clipboard
open override fun poller(pollerMetadata: PollerMetadata): FilterEndpointSpec
open fun poller(pollers: Function<PollerFactory, PollerSpec>): FilterEndpointSpec
open fun poller(pollerMetadataSpec: PollerSpec): FilterEndpointSpec
reactive
Link copied to clipboard
open fun reactive(): FilterEndpointSpec
open fun reactive(reactiveCustomizer: Function<in Flux<Message<*>>, out Publisher<Message<*>>>): FilterEndpointSpec
requiresReply
Link copied to clipboard
open fun requiresReply(requiresReply: Boolean): FilterEndpointSpec
role
Link copied to clipboard
open override fun role(role: String): FilterEndpointSpec
sendTimeout
Link copied to clipboard
open fun sendTimeout(sendTimeout: Long): FilterEndpointSpec
setBeanClassLoader
Link copied to clipboard
open override fun setBeanClassLoader(p0: ClassLoader)
setBeanFactory
Link copied to clipboard
open override fun setBeanFactory(@Nullable p0: BeanFactory)
setSingleton
Link copied to clipboard
open fun setSingleton(p0: Boolean)
start
Link copied to clipboard
open override fun start()
stop
Link copied to clipboard
open override fun stop()
open override fun stop(callback: Runnable)
taskScheduler
Link copied to clipboard
open fun taskScheduler(taskScheduler: TaskScheduler): FilterEndpointSpec
throwExceptionOnRejection
Link copied to clipboard
fun throwExceptionOnRejection(throwExceptionOnRejection: Boolean)
transactional
Link copied to clipboard
open fun transactional(): FilterEndpointSpec
open fun transactional(handleMessageAdvice: Boolean): FilterEndpointSpec
open fun transactional(transactionManager: TransactionManager): FilterEndpointSpec
open fun transactional(transactionInterceptor: TransactionInterceptor): FilterEndpointSpec
open fun transactional(transactionManager: TransactionManager, handleMessageAdvice: Boolean): FilterEndpointSpec

Properties

adviceChain
Link copied to clipboard
val adviceChain: MutableList<Advice>
componentsToRegister
Link copied to clipboard
val componentsToRegister: MutableMap<Any, String>
delegate
Link copied to clipboard
val delegate: FilterEndpointSpec

the FilterEndpointSpec this instance is delegating to.

endpointFactoryBean
Link copied to clipboard
val endpointFactoryBean: ConsumerEndpointFactoryBean
handler
Link copied to clipboard
val handler: MessageFilter
logger
Link copied to clipboard
val logger: Log
target
Link copied to clipboard
val target: Tuple2<ConsumerEndpointFactoryBean, MessageFilter>