Be more paranoid around message event handling

giraffi / fluent-plugin-amqp

Use AMQP broker to send or receive messages via FluentD

MIT License

15 stars 31 forks source link

Closed warmfusion closed 8 years ago

warmfusion commented 8 years ago

I've been seeing failures to resume from buffered events caused by this plugin failing to process events on a ruby 1.9.3 server.

As such, I've added more paranoid message handling and a specific catch for a case seen in production;

2016-09-12 10:22:56 +0000 [error]: Malformed msgpack - Did your server run out of space during buffering? invalid byte

warmfusion commented 8 years ago

cough

sawanoboly commented 8 years ago

Oh, sorry for delay.

sawanoboly commented 8 years ago

Thanks, released 👍

Pushed fluent-plugin-amqp 0.9.2 to rubygems.org.