Logstash + stomp + ActiveMQ

Question

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

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

ActiveMQ网站说我需要告诉我的stomp生产者添加“persistent：true”参数，但我没有在logstash网站上找到任何关于此的文档。

谁知道这个呢？

提前致谢，

Answer 1

好吧，无法在logstash stomp输出上设置持久性。

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

你可以找到文件here：

这一行：

@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
  }
}