Annotation Type Transformer
@Target({METHOD,ANNOTATION_TYPE}) @Retention(RUNTIME) @Documented public @interface Transformer
Indicates that a method is capable of transforming a message, message header,
or message payload.
- Author:
- Mark Fisher, Gary Russell, Artem Bilan
-
Optional Element Summary
Optional Elements Modifier and Type Optional Element Description String[]adviceChainSpecify a "chain" ofAdviceobjects that will "wrap" the message handler.StringautoStartupTheSmartLifecycleautoStartupoption.StringinputChannelSpecify the channel from which this transformer will consume messages.StringoutputChannelSpecify the channel to which this transformer will send the transformed message.StringphaseSpecify aSmartLifecyclephaseoption.Poller[]pollerReactivereactiveStringsendTimeoutSpecify the maximum amount of time in milliseconds to wait when sending a replyMessageto theoutputChannel.
-
Element Details
-
inputChannel
String inputChannelSpecify the channel from which this transformer will consume messages. If the channel does not exist, aDirectChannelwith this name will be registered in the application context.- Returns:
- The channel name.
- Default:
- ""
-
outputChannel
String outputChannelSpecify the channel to which this transformer will send the transformed message.- Returns:
- The channel name.
- Default:
- ""
-
adviceChain
String[] adviceChainSpecify a "chain" ofAdviceobjects that will "wrap" the message handler. Only the handler is advised, not the downstream flow.- Returns:
- the advice chain.
- Default:
- {}
-
sendTimeout
String sendTimeoutSpecify the maximum amount of time in milliseconds to wait when sending a replyMessageto theoutputChannel. Defaults to-1- blocking indefinitely. It is applied only if the output channel has some 'sending' limitations, e.g.QueueChannelwith fixed a 'capacity'. In this case aMessageDeliveryExceptionis thrown. The 'sendTimeout' is ignored in case ofAbstractSubscribableChannelimplementations. Can be specified as 'property placeholder', e.g.${spring.integration.sendTimeout}.- Returns:
- The timeout for sending results to the reply target (in milliseconds)
- Default:
- ""
-
autoStartup
String autoStartupTheSmartLifecycleautoStartupoption. Can be specified as 'property placeholder', e.g.${foo.autoStartup}. Defaults totrue.- Returns:
- the auto startup
booleanflag.
- Default:
- ""
-
phase
String phaseSpecify aSmartLifecyclephaseoption. DefaultsInteger.MAX_VALUE / 2forPollingConsumerandInteger.MIN_VALUEforEventDrivenConsumer. Can be specified as 'property placeholder', e.g.${foo.phase}.- Returns:
- the
SmartLifecyclephase.
- Default:
- ""
-
poller
Poller[] poller- Returns:
- the
Polleroptions for a polled endpoint (PollerMetadata). This attribute is anarrayjust to allow an empty default (no poller). Mutually exclusive withreactive().
- Default:
- {}
-
reactive
Reactive reactive- Default:
- @org.springframework.integration.annotation.Reactive("\n\t\t\n\t\t\n\ue000\ue001\ue002\n\t\t\t\t\n")
-