如何解决如何使用微配置响应式消息传递刷新并发送获取数据的请求
我正在尝试制作一个网络应用程序,我想在刷新网络时收到一条消息(这是我制作的一个简单示例,因为它更容易理解)。我尝试过内部渠道,但我也尝试过 Kafka,但它也不起作用。
失败消息是“未找到频道“通知刷新”的订阅者”。当我用 kafka 尝试时,没有错误,但它没有检索到消息。
我的资源: 它返回一个发布者是因为主应用程序具有的功能而不是这个可重现的示例,但这不是问题。
@ApplicationScoped
@Path("/refresh")
public class refresh {
@Inject
@Channel("notify-refresh")
Emitter<String> emitter;
@Inject
@Channel("uploaded")
Publisher<String> publisher;
@GET
@Produces(MediaType.SERVER_SENT_EVENTS)
@SseElementType(MediaType.TEXT_PLAIN)
public Publisher<String> hello() {
emitter.send("lets go");
return publisher;
}
}
然后这个类接收消息,进行一些更改并发送到处理器:
@ApplicationScoped
public class generator {
@Incoming("notify-refresh")
@Outgoing("send-processor")
public String sendToProcessor(String uni){
return uni;
}
}
返回资源的处理器:
@ApplicationScoped
public class processor {
@Incoming("send-processor")
@Outgoing("uploaded")
public String processMsg(String uni){
return uni;
}
}
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。