Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Logstash messages are not persistent #48

Open
CVTJNII opened this issue Jun 6, 2016 · 0 comments
Open

Logstash messages are not persistent #48

CVTJNII opened this issue Jun 6, 2016 · 0 comments

Comments

@CVTJNII
Copy link

CVTJNII commented Jun 6, 2016

With Logstash 2.2.2 I'm noticing message loss when the Logstash input listeners are restarted. Looking in the RabbitMQ management UI with the input listeners off I see none of the messages are marked as persistent. Looking in the code this is unexpected, the persistent bit should be true by default:

https://github.com/logstash-plugins/logstash-output-rabbitmq/blob/master/lib/logstash/outputs/rabbitmq.rb#L37
https://github.com/logstash-plugins/logstash-output-rabbitmq/blob/master/lib/logstash/outputs/rabbitmq.rb#L54

However, looking at the 'Message Durability' section of http://rubymarchhare.info/articles/durability.html I believe the persistent flag is being passed incorrectly. Per http://rubymarchhare.info/articles/durability.html the :persistent => @Persistent hash key should not be wrapped in :properties, but instead should be passed directly to @hare_info.exchange.publish.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

1 participant