Spring云流：Global errorChannel不工作

Question

根据本文档，应该可以订阅Spring Integration提供的全局错误通道--“ErrorChannel”。

在我这个非常简单的例子中，它不起作用：

应用：

@SpringBootApplication
@EnableBinding({MySink.class})
public class LoggingConsumerApplication {

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

    @StreamListener(target = MySink.INPUT_ONE)
    public void handle(Person person) {
        System.out.println("Received: " + person);

        if(StringUtils.isEmpty(person.getName())){
            throw new RuntimeException("Wrong person name!");
        }
    }

    @ServiceActivator(inputChannel = "mySink.mySink-group.errors")
    public void error(Message<?> message) {
        System.out.println("Handling ERROR: " + message);
    }


    @ServiceActivator(inputChannel = "errorChannel")
    public void errorGlobal(ErrorMessage message) {
        System.out.println("Handling ERROR GLOBAL SA: " + message);
    }

    @StreamListener("errorChannel")
    public void errorGlobalListener(ErrorMessage message) {
        System.out.println("Handling ERROR GLOBAL Listener: " + message);
    }

    public static class Person {
        private String name;
        public String getName() {
            return name;
        }
        public void setName(String name) {
            this.name = name;
        }
        public String toString() {
            return this.name;
        }
    }
}

public interface MySink {

    /**
     * Input channel name.
     */
    String INPUT_ONE = "inputOne";

    /**
     * @return input channel.
     */
    @Input(MySink.INPUT_ONE)
    SubscribableChannel inputOne();
}

spring.rabbitmq.host=192.168.0.100
spring.cloud.stream.bindings.inputOne.destination=mySink
spring.cloud.stream.bindings.inputOne.group=mySink-group

Answer 1

没有任何问题，它正在按预期工作。doc中：“订阅名为input的通道的handle（..）方法引发异常。如果还有错误通道input.mygroup.errors的订阅者，则所有错误消息都由该订阅者处理。”因此，这意味着您的错误可以通过绑定特定错误处理程序(mysink.mysink-group.errors)或全局(errorchannel)来处理。

https://cloud.spring.io/spring-cloud-static/spring-cloud-stream/2.2.0.release/spring-cloud-stream.html#spring-cloud-stream-overview-error-handling