具有logstash jms输入插件的持久订阅者

Question

我需要将来自ActiveMQ代理的文档编入Elasticsearch。我为此目的使用logstash，并使用JMS输入插件（这是基于jriver-jms构建的）。由于我需要确保存储在ActiveMQ代理主题中的每个文档都进入Elasticsearch，因此我希望通过logstash建立持久订阅。我怎样才能做到这一点 ？ JMS输入插件配置中没有诸如“持久”之类的参数。

Answer 1

您可以添加jms.clientID参数（http://activemq.apache.org/connection-configuration-uri.html）插入连接URL