activemq-cpp pull consumer 接收远程地址

Posted

技术标签:

【中文标题】activemq-cpp pull consumer 接收远程地址【英文标题】:activemq-cpp pull consumer receive remote address 【发布时间】:2020-11-22 21:16:01 【问题描述】:

我有 2 个带有队列的 activeMQ 代理,我希望能够记录传入的 ActiveMQ 消息代理远程地址。

执行拉取消费者接收后: pull_consumer->receive(1000);

消息到达后,我这样做: ActiveMQConnection *amqconn = dynamic_cast<ActiveMQConnection*>(connection);

然后尝试获取远程地址: amqconn->getTransport().getRemoteAddress().c_str() 但它总是空的

我检查了getTransport().isClosed()getTransport().isConnected(),它们没有关闭和连接

或者是否有其他方法可以检索此连接信息?

【问题讨论】:

【参考方案1】:

可能是客户端存在一个错误,导致该值无法被填充,或者该位从一开始就没有实现。 ActiveMQ C++ 客户端不再被维护,因此如果有任何真正的答案或支持,您不太可能收到太多。我的建议是从使用 AMQP 1.0 协议的 Apache Qpid 项目转移到类似 C++ 客户端。

【讨论】:

以上是关于activemq-cpp pull consumer 接收远程地址的主要内容,如果未能解决你的问题,请参考以下文章

activemq-cpp编译

Kafka有个啥参数可以让consumer阻塞知道新消息到达?

kafka是pull还是push及优劣分析?

kafka是pull还是push及优劣分析?

Kafka消息是采用Pull模式,还是Push模式?

ActiveMQ-cpp:尽管发生故障转移,但连接丢失