错误:无法指定多个目的地

用户2225713

我正在尝试配置向两个输出流发送消息,如下所示。

@StreamListener(SampleBinding.INPUT1)
@SendTo({SampleBinding.OUTPUT1, SampleBinding.OUTPUT2})
public String handleM(String sampleMessage){
    log.info("Received message="+sampleMessage.toString());
    sampleMessage=sampleMessage.toUpperCase();
    return sampleMessage;
}

我跟着这个例子

它给出了以下错误。

java.lang.IllegalArgumentException:无法在 org.springframework.util.Assert.isTrue(Assert.java:118) at org.springframework.cloud.stream.binding.StreamListenerMethodUtils.getOutboundBindingTargetName(StreamListenerMethodUtils.java:146) at 指定多个目的地org.springframework.cloud.stream.binding.StreamListenerAnnotationBeanPostProcessor$DefaultStreamListenerSetupMethodOrchestrator.orchestrateStreamListenerSetupMethod(StreamListenerAnnotationBeanPostProcessor.java:349) at org.springframework.cloud.stream.binding.StreamListenerAnnotationBeanPostProcessor.doPostProcess(StreamListenerAnnotation:BeanPostProcessor.java:349) java.lang.Iterable 中的 stream.binding.StreamListenerAnnotationBeanPostProcessor.lambda$postProcessAfterInitialization$0(StreamListenerAnnotationBeanPostProcessor.java:167)。forEach(Ite​​rable.java:75) 在 org.springframework.cloud.stream.binding.StreamListenerAnnotationBeanPostProcessor.injectAndPostProcessDependencies(StreamListenerAnnotationBeanPostProcessor.java:285) 在 org.springframework.cloud.stream.binding.StreamListenerAnnotationBeanPostProcessor.afterSingletListenerAnnotationBean1 或 PostProcessDependencies(StreamListenerAnnotationBeanPostProcessor.java:285)在 org.springframework.beans.factory.support.DefaultListableBeanFactory.preInstantiateSingletons(DefaultListableBeanFactory.java:863) 在 org.springframework.context.support.AbstractApplicationContext.finishBeanFactoryInitialization(AbstractApplicationContext.java:863) 在 org.springframework.context.support.Abs .refresh(AbstractApplicationContext.java:546) 在 org.springframework.boot.web.servleStreamListenerAnnotationBeanPostProcessor.injectAndPostProcessDependencies(StreamListenerAnnotationBeanPostProcessor.java:285) 在 org.springframework.cloud.stream.binding.StreamListenerAnnotationBeanPostProcessor.afterSingletonsInstantiated(StreamListenerAnnotationBeanPostProcessor.java:105) 在 org.springframework.stream.binding.StreamListenerAnnotationBeanPostProcessor.afterSingletonsInstantiated(StreamListenerAnnotationBeanPostProcessor.java:105) 863) 在 org.springframework.context.support.AbstractApplicationContext.finishBeanFactoryInitialization(AbstractApplicationContext.java:863) 在 org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:546) 在 org.springframework.boot.web.servleStreamListenerAnnotationBeanPostProcessor.injectAndPostProcessDependencies(StreamListenerAnnotationBeanPostProcessor.java:285) 在 org.springframework.cloud.stream.binding.StreamListenerAnnotationBeanPostProcessor.afterSingletonsInstantiated(StreamListenerAnnotationBeanPostProcessor.java:105) 在 org.springframework.stream.binding.StreamListenerAnnotationBeanPostProcessor.afterSingletonsInstantiated(StreamListenerAnnotationBeanPostProcessor.java:105) 863) 在 org.springframework.context.support.AbstractApplicationContext.finishBeanFactoryInitialization(AbstractApplicationContext.java:863) 在 org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:546) 在 org.springframework.boot.web.servleStreamListenerAnnotationBeanPostProcessor.afterSingletonsInstantiated(StreamListenerAnnotationBeanPostProcessor.java:105) 在 org.springframework.beans.factory.support.DefaultListableBeanFactory.preInstantiateSingletons(DefaultListableBeanFactory.java:863) 在 org.springframework.context.support.AbsishBeanFactoryInitApplication6Initialization(StreamListenerAnnotationBeanPostProcessor.java:105)在 org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:546) 在 org.springframework.boot.web.servleStreamListenerAnnotationBeanPostProcessor.afterSingletonsInstantiated(StreamListenerAnnotationBeanPostProcessor.java:105) 在 org.springframework.beans.factory.support.DefaultListableBeanFactory.preInstantiateSingletons(DefaultListableBeanFactory.java:863) 在 org.springframework.context.support.AbsishBeanFactoryInitApplication6Initialization(StreamListenerAnnotationBeanPostProcessor.java:105)在 org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:546) 在 org.springframework.boot.web.servleFinishBeanFactoryInitialization(AbstractApplicationContext.java:863) 在 org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:546) 在 org.springframework.boot.web.servleFinishBeanFactoryInitialization(AbstractApplicationContext.java:863) 在 org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:546) 在 org.springframework.boot.web.servle

索比查科

StreamListener使用MessageChannel基于常规的活页夹时,无法像您从方法中描述的那样发送到多个目的地可以使用上面提供的链接中提到的 Kafka Streams 绑定器的分支功能发送到多个主题。如果要发送到应用程序中的多个目的地,一种选择是使用 Spring Cloud Stream 的动态目的地功能。以下是动态目的地如何工作的示例

本文收集自互联网,转载请注明来源。

如有侵权,请联系[email protected] 删除。

编辑于
0

我来说两句

0条评论
登录后参与评论

相关文章

来自分类Dev

设置目的地是错误的

来自分类Dev

无法指定扩展模块的目的地,无法添加python模块

来自分类Dev

无法更改符号链接的目的地

来自分类Dev

无法更改符号链接的目的地

来自分类Dev

ssh无法到达目的地

来自分类Dev

如何为现有ClaimsIdentity指定目的地?

来自分类Dev

没有指定目的地的`mv ./*`有什么作用?

来自分类Dev

春云| 收集来自多个目的地的响应

来自分类Dev

将文件移动到多个目的地

来自分类Dev

错误:查询没有结果数据的目的地

来自分类Dev

INSERT INTO错误:结果数据无目的地

来自分类Dev

move_uploaded_file保存在错误的目的地

来自分类Dev

错误:查询没有结果数据的目的地

来自分类Dev

Web部署任务失败。无法到达目的地

来自分类Dev

在omnet ++中到达目的地时无法删除味精?

来自分类Dev

Robocopy无法区分目的地和来源

来自分类Dev

OpenConnect无法到达仅VPN目的地

来自分类Dev

文件上传目的地

来自分类Dev

目的地是必填项

来自分类Dev

(.Copy)目的地:=空

来自分类Dev

(。复制)目的地:=空

来自分类Dev

Xamarin NSDragging目的地

来自分类Dev

Gtts 改变目的地

来自分类Dev

修改响应的目的地

来自分类Dev

Stripe Connect - 为多个目的地费用创建多个代币

来自分类Dev

从用户指定的方向而非最终目的地建立建筑物的导航路线

来自分类Dev

当单击键盘时,Android EditText指定下一个目的地

来自分类Dev

像Bellman-Ford这样的算法,仅适用于多个起点,单个目的地?

来自分类Dev

ln -s:从一个来源到多个目的地