Spring Cloud Stream Service-Bus Binder的错误通道

Question

我正在尝试为Spring Cloud Azure Service Bus Queue Stream Binder 配置错误通道，但没有成功。我已经通过

启用了错误通道

spring:
  cloud:
    stream:
      function:
        definition: produce
      bindings:
        produce-out-0:
          destination: service-bus-q-a
          producer:
            error-channel-enabled: true

并尝试定义@ServiceActivator：

@ServiceActivator(inputChannel = "service-bus-q-a.errors")
public void errors(ErrorMessage receiveMsg) {
    System.err.println("receive error msg: " + receiveMsg);
}

我也试过inputChannel = "errorChannel" 和inputChannel = "service-bus-q-a.$Default.errors"。显然我在这里遗漏了一些东西，但我找不到一个可行的例子。

编辑：我正在使用以下供应商 bean：

@Bean
Supplier<String> produce() {
    return () -> {
        String msg = "a message to produce";
        LOG.info("Producing message: " + msg);
        return msg;
    };
}

根据binding naming conventions，绑定的名称将是produce-out-0。我可以看到消息确实发送到service-bus-q-a（我在另一边有一个消费者）。

编辑和解决方案：

所以看来我的环境有问题，在重建它之后，一切都按预期工作，就像Garry Russell's answer shows。很抱歉浪费了时间。 对于后代来说，这正是对我有用的：

声明绑定时

spring:
  cloud:
    stream:
      bindings:
        produce-out-0:
          destination: service-bus-q-a
          producer:
            error-channel-enabled: true

将创建的错误通道将命名为{destination}.errors，在本例中为service-bus-q-a.errors。此外，您还有全局错误通道errorChannel，如果发生错误，也会调用该通道。所以你可以使用任何一个

@ServiceActivator(inputChannel = "service-bus-q-a.errors")
public void errors(ErrorMessage receiveMsg) {
    System.err.println("receive error msg: " + receiveMsg);
}

接收来自service-bus-q-a 的错误或

@ServiceActivator(inputChannel = "errorChannel")
public void errors(ErrorMessage receiveMsg) {
    System.err.println("receive error msg: " + receiveMsg);
}

从全局错误通道接收错误。

Answer 1

我刚刚用这个 yaml 测试了它，属性是true，正如预期的那样。

spring:
  cloud:
    stream:
      bindings:
        output:
          producer:
            error-channel-enabled: true
    azure:
      servicebus:
        connectionString: Endpoint=sb://foo.bar

您确定您的制作人姓名 (produce-out-0) 正确吗？