在Spring Boot的主应用程序类之外时,@StreamListener不可见.原因可能是什么



这是Spring Cloud Stream应用程序。正如我在标题中提到的,StreamListener注释在SpringBootApplication主类中工作,但在具有@Component注释的其他类中不工作。

我认为这是某种StreamListener可见性问题。

我正在从RabbitMQ管理界面发布消息。

以下是我得到的例外:

ERROR 10676 --- [Service-Group-1] o.s.integration.handler.LoggingHandler   : org.springframework.messaging.MessageDeliveryException: Dispatcher has no subscribers for channel 'Consumer-Slide.slideInputStream'.; nested exception is org.springframework.integration.MessageDispatchingException: Dispatcher has no subscribers

ConsumerApplication.java

@SpringBootApplication
@EnableBinding(SlideChannel.class)
public class ConsumerApplication {

public static void main(String[] args) {
SpringApplication.run(ConsumerApplication.class, args);

}
}

SlideChannel.java

public interface SlideChannel {
String slideInputStream = "slideInputStream";

@Input(SlideChannel.slideInputStream)
SubscribableChannel slideInput();
}

SlideListener.java

@Component
public class SlideListener {

@Autowired
private SlideChannel slideCh;


@Autowired
private SlideService slideService;

@StreamListener(target=SlideChannel.slideInputStream)
public void getSingleSlideDetails(Message<?> messageId) {
System.out.println("Message consumed");

}
}

应用程序属性

spring.rabbitmq.host=localhost
spring.rabbitmq.port=5672
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest
spring.cloud.stream.rabbit.bindings.slideInputStream.consumer.consumerTagPrefix=SlideConsumer
spring.cloud.stream.bindings.slideInputStream.destination=EventbusRouter
spring.cloud.stream.bindings.slideInputStream.group=Slide-Consumer-Service-Group
spring.cloud.stream.rabbit.bindings.slideInputStream.consumer.exchangeDurable=false
spring.cloud.stream.rabbit.bindings.slideInputStream.consumer.bind-queue=true
spring.cloud.stream.rabbit.bindings.slideInputStream.consumer.bindingRoutingKey=SlideTopic
spring.cloud.stream.rabbit.bindings.slideInputStream.consumer.durableSubscription=false

我可以自己回答,因为应用程序按预期工作。

解决方案:将应用程序文件保留在父包中,以便它可以扫描子模块。(据我所知(。