反应性消息传递-- ClassCastException不能转换为io.smallrye.mutiny.Multi类

Question

@Incoming("from-processor-to-consumer")
public Multi<Void> consume(Multi<String> stream) {
    return stream.onItem()
            .invoke(msg -> {
                log.infof("consumer received %s", msg);
            })
            .onItem()
            .ignore();
}

运行此方法时，将引发ClassCastException

consume has thrown an exception: java.lang.ClassCastException: class java.lang.String cannot be cast to class io.smallrye.mutiny.Multi

我可以消费Multi<String>吗？

从SmallRye Reactive Messaging > Development Model > Consuming Payloads的角度来看，我似乎只能同时使用一条消息。

Answer 1

首先，我必须承认，错误信息是无用的，应该加以改进。

问题在于您的应用程序签名。

@Incoming("from-processor-to-consumer")
@Outgoing("this-is-missing-in-your-code")
public Multi<Void> consume(Multi<String> stream) {
    return stream.onItem()
            .invoke(msg -> {
                log.infof("consumer received %s", msg);
            })
            .onItem()
            .ignore();
}

缺少@Outgoing注释。当返回一个Multi,时，您需要说“在哪里”。

如果您的方法是终端(意思是最终的使用者)，则不能注入Multi。解决方法是使用一个简单的非操作方法：

@Incoming("from-processor-to-consumer")
@Outgoing("this-is-missing-in-your-code")
public Multi<String> consume(Multi<String> stream) {
    return stream.onItem()
            .invoke(msg -> {
                log.infof("consumer received %s", msg);
            });
}


@Incoming("this-is-missing-in-your-code")
void noop(String s) { }