这是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
我可以自己回答,因为应用程序按预期工作。
解决方案:将应用程序文件保留在父包中,以便它可以扫描子模块。(据我所知(。