diff --git a/spring-context/src/main/java/org/springframework/messaging/channel/BeanFactoryChannelResolver.java b/spring-context/src/main/java/org/springframework/messaging/channel/BeanFactoryMessageChannelDestinationResolver.java similarity index 65% rename from spring-context/src/main/java/org/springframework/messaging/channel/BeanFactoryChannelResolver.java rename to spring-context/src/main/java/org/springframework/messaging/channel/BeanFactoryMessageChannelDestinationResolver.java index 3254af6565..bc8007e53a 100644 --- a/spring-context/src/main/java/org/springframework/messaging/channel/BeanFactoryChannelResolver.java +++ b/spring-context/src/main/java/org/springframework/messaging/channel/BeanFactoryMessageChannelDestinationResolver.java @@ -15,8 +15,10 @@ */ package org.springframework.messaging.channel; +import org.springframework.beans.BeansException; import org.springframework.beans.factory.BeanFactory; import org.springframework.messaging.MessageChannel; +import org.springframework.messaging.core.DestinationResolutionException; import org.springframework.messaging.core.DestinationResolver; import org.springframework.util.Assert; @@ -25,12 +27,12 @@ import org.springframework.util.Assert; * @author Mark Fisher * @since 4.0 */ -public class BeanFactoryChannelResolver implements DestinationResolver { +public class BeanFactoryMessageChannelDestinationResolver implements DestinationResolver { private final BeanFactory beanFactory; - public BeanFactoryChannelResolver(BeanFactory beanFactory) { + public BeanFactoryMessageChannelDestinationResolver(BeanFactory beanFactory) { Assert.notNull(beanFactory, "beanFactory must not be null"); this.beanFactory = beanFactory; } @@ -38,7 +40,14 @@ public class BeanFactoryChannelResolver implements DestinationResolver { - D resolveDestination(String name); + + /** + * @param name + * @return + * @throws DestinationResolutionException + */ + D resolveDestination(String name) throws DestinationResolutionException; } diff --git a/spring-context/src/main/java/org/springframework/messaging/core/GenericMessagingTemplate.java b/spring-context/src/main/java/org/springframework/messaging/core/GenericMessagingTemplate.java index 12bd2498c2..de18bf79b5 100644 --- a/spring-context/src/main/java/org/springframework/messaging/core/GenericMessagingTemplate.java +++ b/spring-context/src/main/java/org/springframework/messaging/core/GenericMessagingTemplate.java @@ -28,7 +28,7 @@ import org.springframework.messaging.MessageChannel; import org.springframework.messaging.MessageDeliveryException; import org.springframework.messaging.MessageHeaders; import org.springframework.messaging.PollableChannel; -import org.springframework.messaging.channel.BeanFactoryChannelResolver; +import org.springframework.messaging.channel.BeanFactoryMessageChannelDestinationResolver; import org.springframework.messaging.support.MessageBuilder; import org.springframework.util.Assert; @@ -79,7 +79,7 @@ public class GenericMessagingTemplate extends AbstractDestinationResolvingMessag @Override public void setBeanFactory(BeanFactory beanFactory) throws BeansException { - super.setDestinationResolver(new BeanFactoryChannelResolver(beanFactory)); + super.setDestinationResolver(new BeanFactoryMessageChannelDestinationResolver(beanFactory)); }