diff --git a/org.springframework.integration/src/main/java/org/springframework/integration/annotation/Poller.java b/org.springframework.integration/src/main/java/org/springframework/integration/annotation/Poller.java index 74a57dffad..dd52a8d4d8 100644 --- a/org.springframework.integration/src/main/java/org/springframework/integration/annotation/Poller.java +++ b/org.springframework.integration/src/main/java/org/springframework/integration/annotation/Poller.java @@ -24,6 +24,8 @@ import java.lang.annotation.RetentionPolicy; import java.lang.annotation.Target; import java.util.concurrent.TimeUnit; +import org.springframework.transaction.annotation.Transactional; + /** * Annotation that can be specified at method-level alongside a Message Endpoint * annotation (e.g. @Splitter, @ChannelAdapter, etc.) in order to provide the @@ -47,4 +49,8 @@ public @interface Poller { int maxMessagesPerPoll() default -1; + Transactional transactionAttributes() default @Transactional; + + String transactionManager() default ""; + }