Logstash + stomp + ActiveMQ

Question

我使用logstash读取CSV文件，并使用stomp协议将信息发布到我的ActiveMQ。

一切都很好，我只想在这些消息中添加持久性，但我不知道如何告诉logstash这样做。

ActiveMQ站点说我需要告诉我的stomp生产者添加"persistent:true“参数，但是我在logstash站点上没有找到关于这个的任何文档。

有人知道这件事吗？

提前谢谢你，

http://activemq.apache.org/stomp.html

Answer 1

好吧，持久性不能设置在logstash stomp输出上。

如果这对您非常重要，那么它应该是源代码中的一个简单的修复。

您可以找到文件这里

这一行：

@client.send(event.sprintf(@destination), event.to_json)

应该是这样的：

@client.send(event.sprintf(@destination), event.to_json, :persistent => true)

你必须构建它并自己安装插件。我的Ruby技能是有限的，所以我不知道如何去做。也许可以考虑将其添加为一个配置参数，并通过一个拉请求来贡献它？

Answer 2

现在，您可以使用属性标头发送持久消息：

stomp {
  host => "localhost"
  port => 61612
  destination => "my_queue"
  headers => {
    "persistent" => true
  }
}

来源：https://github.com/logstash-plugins/logstash-output-stomp/issues/7