具有Opentracing的Microprofile Reactive消息传递
我正在玩MP Reactive Messaging和MP Opentracing,但我不知道如何跟踪通过Reactive Messaging发送的消息。
甚至有可能跟踪带有@income/@output注释的方法吗？
共有1个答案
您应该找到一个扩展Import org.eclipse.microprofile.reactive.messaging.spi.IncomingConnectorFactory；的类，后者专用于@incoming和Import org.eclipse.microprofile.reactive.messaging.spi.OutgoingConnectorFactory；的类
这取决于您正在使用的扩展。您应该拥有这一点，因为它是连接器或发送和接收消息到通道的部分
-
我对Spring集成相对较新，但我的任务是实现一个tcp网关，该网关需要： 在套接字上侦听消息 在我的Spring集成经验中，消息流不是双向的。我只将路由器配置为侦听、处理消息和输出到队列/主题。但是，在这种情况下，我需要接受消息并返回响应，同时将某些消息转发到队列。建议？ 这是到目前为止我的集成xml。 如何将handleInput的输出转发到队列，同时从网关返回一些响应？ 编辑：在与Gary进
-
由于内容脚本在网页而不是扩展程序的上下文中运行，因此它们通常需要某种与扩展程序其余部分进行通信的方式。例如，RSS 阅读器扩展程序可以使用内容脚本来检测页面上 RSS 摘要的存在，然后通知后台页面以显示该页面的操作图标。 扩展及其内容脚本之间的通信使用消息传递来实现。任何一方都可以监听从另一端发送的消息，并在同一通道上进行响应。消息可以包含任何有效的 JSON 对象（空，布尔值，数字，字符串，数组
-
ms tcp nodelay 描述: 在信差的 TCP 会话上禁用 nagle 算法。 类型: Boolean 是否必需: No 默认值: true ms initial backoff 描述: 出错时重连的初始等待时间。 类型: Double 是否必需: No 默认值: .2 ms max backoff 描述: 出错重连时等待的最大时间。 类型: Double 是否必需: No 默认值: 15
-
消息传递 目录 一次简单的请求 h3Name 长时间保持连接 h3Name 扩展之间的消息传递 h3Name 安全策略 h3Name 范例 h3Name API reference Properties propertyName Methods methodName Events eventName Types id For information on how to use experiment
-
本文向大家介绍传统的消息传递方法有哪些类型？相关面试题，主要包含被问及传统的消息传递方法有哪些类型？时的应答技巧和注意事项，需要的朋友参考一下 答：基本上，传统的消息传递方法有两种，如： 排队：这是一种消费者池可以从服务器读取消息并且每条消息转到其中一个消息的方法。 发布-订阅：在发布-订阅中，消息被广播给所有消费者。
-
抱歉，我需要先解释一下，然后再谈这个问题。 异步： 我可以使用Kafka producer async send with with callback，如果向Kafka发送消息时出现错误，那么通知JMS使用者不确认消息消耗将为时已晚。为了克服这个问题，我想出的唯一办法是，如果有异常，在回调中保留消息，然后尝试稍后发送消息。但我认为那会是太多的开销。 有没有其他方法可以使用异步调用来处理这种情况？