Not flushing batching codecs on shut down.

On shut down, there is no way to signal a batching codec that it should flush it's contents. This results in message loss.

As a work around, have made the following local patch to the RabbitMQ output plugin
def close
+ # Close the codec if it supports this, to flush any outstanding entries
+ # needed for buffering codecs.
+ codec.do_close if codec.respond_to?( :do_close)
close_connection
end

Is there a better way to do this?