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

KotlinTransformerEndpointSpec

class KotlinTransformerEndpointSpec : TransformerEndpointSpec

A TransformerEndpointSpec wrapped for Kotlin DSL.

Author

Artem Bilan

Since

6.2

Constructors

KotlinTransformerEndpointSpec

constructor()

Properties

@get:Nullable

Functions

open fun advice(vararg advice: Advice): TransformerEndpointSpec

afterPropertiesSet

open override fun afterPropertiesSet()

open fun async(async: Boolean): TransformerEndpointSpec

open override fun autoStartup(autoStartup: Boolean): TransformerEndpointSpec

customizeMonoReply

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

open override fun destroy()

open fun <P : Any> expectedType(@Nullable expectedType: Class<P>): TransformerEndpointSpec

open fun expression(expression: String): TransformerEndpointSpec

open fun expression(expression: Expression): TransformerEndpointSpec

getComponentsToRegister

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

@NonNull

open override fun getObject(): Tuple2<ConsumerEndpointFactoryBean, MessageTransformingHandler>

open override fun getObjectType(): Class<*>

open override fun getPhase(): Int

handleMessageAdvice

open fun handleMessageAdvice(vararg interceptors: MethodInterceptor): TransformerEndpointSpec

open override fun id(@Nullable id: String): TransformerEndpointSpec

open override fun isAutoStartup(): Boolean

open override fun isRunning(): Boolean

open fun isSingleton(): Boolean

open fun method(@Nullable method: String): TransformerEndpointSpec

notPropagatedHeaders

open fun notPropagatedHeaders(vararg headerPatterns: String): TransformerEndpointSpec

open fun order(order: Int): TransformerEndpointSpec

open override fun phase(phase: Int): TransformerEndpointSpec

open override fun poller(pollerMetadata: PollerMetadata): TransformerEndpointSpec

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

open fun poller(pollerMetadataSpec: PollerSpec): TransformerEndpointSpec

open fun processor(processor: MessageProcessorSpec<*>): TransformerEndpointSpec

open fun reactive(): TransformerEndpointSpec

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

open fun ref(ref: Any): TransformerEndpointSpec

open fun refName(refName: String): TransformerEndpointSpec

open fun requiresReply(requiresReply: Boolean): TransformerEndpointSpec

open override fun role(role: String): TransformerEndpointSpec

open fun sendTimeout(sendTimeout: Long): TransformerEndpointSpec

open override fun start()

open override fun stop()

open override fun stop(callback: Runnable)

open fun taskScheduler(taskScheduler: TaskScheduler): TransformerEndpointSpec

open fun transactional(): TransformerEndpointSpec

open fun transactional(handleMessageAdvice: Boolean): TransformerEndpointSpec

open fun transactional(transactionManager: TransactionManager): TransformerEndpointSpec

open fun transactional(transactionInterceptor: TransactionInterceptor): TransformerEndpointSpec

open fun transactional(transactionManager: TransactionManager, handleMessageAdvice: Boolean): TransformerEndpointSpec

inline fun <P> transformer(crossinline function: (P) -> Any)

Provide a Kotlin function as a direct delegate for MessageTransformingHandler.

open fun <P : Any, T : Any> transformer(transformer: GenericTransformer<P, T>): TransformerEndpointSpec