KotlinFilterEndpointSpec

An FilterEndpointSpec wrapped for Kotlin DSL.

Author

Artem Bilan

Since

5.3

Constructors

Link copied to clipboard

Functions

Link copied to clipboard
open fun advice(vararg advice: Advice): FilterEndpointSpec
Link copied to clipboard
open override fun afterPropertiesSet()
Link copied to clipboard
open fun async(async: Boolean): FilterEndpointSpec
Link copied to clipboard
open override fun autoStartup(autoStartup: Boolean): FilterEndpointSpec
Link copied to clipboard
open fun <T : Any, V : Any> customizeMonoReply(replyCustomizer: BiFunction<Message<*>, Mono<T>, Publisher<V>>): FilterEndpointSpec
Link copied to clipboard
open override fun destroy()
Link copied to clipboard
fun discardChannel(discardChannelName: String)
fun discardChannel(discardChannel: MessageChannel)
Link copied to clipboard
Link copied to clipboard
fun discardWithinAdvice(discardWithinAdvice: Boolean)
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
open override fun getObjectType(): Class<*>
Link copied to clipboard
open override fun getPhase(): Int
Link copied to clipboard
open fun handleMessageAdvice(vararg interceptors: MethodInterceptor): FilterEndpointSpec
Link copied to clipboard
open override fun id(id: String): FilterEndpointSpec
Link copied to clipboard
open override fun isAutoStartup(): Boolean
Link copied to clipboard
open override fun isRunning(): Boolean
Link copied to clipboard
open fun notPropagatedHeaders(vararg headerPatterns: String): FilterEndpointSpec
Link copied to clipboard
open fun order(order: Int): FilterEndpointSpec
Link copied to clipboard
open override fun phase(phase: Int): FilterEndpointSpec
Link copied to clipboard
open override fun poller(pollerMetadata: PollerMetadata): FilterEndpointSpec
open fun poller(pollerMetadataSpec: PollerSpec): FilterEndpointSpec
Link copied to clipboard
open fun reactive(reactiveCustomizer: Function<in Flux<Message<*>>, out Publisher<Message<*>>>): FilterEndpointSpec
Link copied to clipboard
open fun requiresReply(requiresReply: Boolean): FilterEndpointSpec
Link copied to clipboard
open override fun role(role: String): FilterEndpointSpec
Link copied to clipboard
open fun sendTimeout(sendTimeout: Long): FilterEndpointSpec
Link copied to clipboard
open override fun setBeanClassLoader(classLoader: ClassLoader)
Link copied to clipboard
open override fun start()
Link copied to clipboard
open override fun stop()
open override fun stop(callback: Runnable)
Link copied to clipboard
open fun taskScheduler(taskScheduler: TaskScheduler): FilterEndpointSpec
Link copied to clipboard
fun throwExceptionOnRejection(throwExceptionOnRejection: Boolean)
Link copied to clipboard
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

Link copied to clipboard
@Nullable
protected var beanFactory: BeanFactory
Link copied to clipboard

the FilterEndpointSpec this instance is delegating to.

Link copied to clipboard
val id: String
Link copied to clipboard