java - 如何 Autowiring Spring Stream 云绑定(bind)

Question

我在 application.yml 中定义了 error 和 notification 绑定(bind)

cloud:
  stream:
    bindings:
      error:
        destination: error
        binder: default
      notification:
        destination: notification
        binder: default

如何在我的组件中获取这些 bean？

我尝试过这种方法:

@Component
class MyComponent {

   @Autowired
   @Qualified("notification")
   MessageChannel notificationChannel;
}

但是找不到notificationChanel。

更新cloud.stream.bindings.* 仅允许配置 channel 。但不创建它。

Answer 1

您确定您有@EnableBinding和适当的接口(interface)来声明@Input或@Output吗？

https://docs.spring.io/spring-cloud-stream/docs/Chelsea.SR2/reference/htmlsingle/index.html#_declaring_and_binding_channels

public interface Barista {

    @Input
    SubscribableChannel orders();

    @Output
    MessageChannel hotDrinks();

    @Output
    MessageChannel coldDrinks();
}

...
@EnableBinding(Barista.class)
public class CafeConfiguration {