问题描述
我有将消息发布到代理的组件我想将相同的消息导出到 prometheus
public class ModuleAMessagePublisher {
@Inject
@Internalbroker
private MessagePublisher messagePublisher;
public void publish(String topic,final String message) {
log.info("<><><><><><><><><> (MQ) PUBLISH MODULEA MESSAGE: <><><><><><<>\n",message);
messagePublisher.publish(topic,message);
// code for prometheus to be added here
}
}
我对使用 prometheus 很陌生,我不确定是否可以完成或如何完成
解决方法
您可以使用提供的 hivemq 扩展来托管您的 hivemq 服务器上的所有指标,如此处所述 -
https://www.hivemq.com/extension/prometheus-extension/
这将在 hivemq 服务器上启用一个 /metrics 端点,您的 prometheus 服务器可以使用该端点。