Spring Cloud Stream服务总线绑定的错误通道

Question

我正在尝试为SpringCloudAzure服务总线队列流绑定器配置错误通道，但未成功。我已通过启用错误通道

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;
    };
}

根据绑定命名约定，绑定的名称将为product-out-0。我可以看到消息确实发送到了service-bus-q-a（另一侧有一个消费者）。

编辑和解决方案：

看来我的环境出了问题，重建后一切都如期进行，正如Garry Russell的回答所示。对不起，耽误了你的时间。对子孙后代来说，这正是我的工作：

声明绑定时

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

将要创建的错误通道将命名为{destination}。错误，在本例中为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

你确定你的生产者名称（product-out-0）是正确的吗？