diff --git a/spring-integration-core/src/main/java/org/springframework/integration/config/annotation/AbstractMethodAnnotationPostProcessor.java b/spring-integration-core/src/main/java/org/springframework/integration/config/annotation/AbstractMethodAnnotationPostProcessor.java index cd559a0b05..048a26b084 100644 --- a/spring-integration-core/src/main/java/org/springframework/integration/config/annotation/AbstractMethodAnnotationPostProcessor.java +++ b/spring-integration-core/src/main/java/org/springframework/integration/config/annotation/AbstractMethodAnnotationPostProcessor.java @@ -29,6 +29,7 @@ import org.springframework.beans.factory.ListableBeanFactory; import org.springframework.beans.factory.config.ConfigurableListableBeanFactory; import org.springframework.core.annotation.AnnotationUtils; import org.springframework.core.annotation.Order; +import org.springframework.integration.channel.DirectChannel; import org.springframework.integration.config.IntegrationConfigUtils; import org.springframework.integration.context.Orderable; import org.springframework.integration.endpoint.AbstractEndpoint; @@ -38,6 +39,7 @@ import org.springframework.integration.support.channel.BeanFactoryChannelResolve import org.springframework.messaging.MessageChannel; import org.springframework.messaging.MessageHandler; import org.springframework.messaging.SubscribableChannel; +import org.springframework.messaging.core.DestinationResolutionException; import org.springframework.messaging.core.DestinationResolver; import org.springframework.util.Assert; import org.springframework.util.ClassUtils; @@ -47,6 +49,7 @@ import org.springframework.util.StringUtils; * Base class for Method-level annotation post-processors. * * @author Mark Fisher + * @author Artem Bilan * @author Gary Russell */ public abstract class AbstractMethodAnnotationPostProcessor implements MethodAnnotationPostProcessor { @@ -133,7 +136,18 @@ public abstract class AbstractMethodAnnotationPostProcessor("foo")); + Message message = this.output.receive(100); + assertNotNull(message); + assertEquals("foo: 1", message.getPayload()); + assertEquals(1, count); + } + @Test(expected = MessageDeliveryException.class) public void stopContext() { applicationContext.stop();