create a flush buffer #at_exit callback to ensure any buffered messages are flushed to Redis on process exit

This commit is contained in:
2011-04-18 12:37:24 +01:00
parent 7b5c308960
commit b13da6f332

View File

@@ -20,6 +20,7 @@ require 'redistat/mixins/options'
require 'redistat/mixins/synchronize'
require 'redistat/mixins/database'
require 'redistat/mixins/date_helper'
require 'redistat/connection'
require 'redistat/buffer'
require 'redistat/collection'
@@ -36,6 +37,7 @@ require 'redistat/version'
require 'redistat/core_ext'
module Redistat
KEY_NEXT_ID = ".next_id"
@@ -91,3 +93,9 @@ module Redistat
end
end
# ensure buffer is flushed on program exit
Kernel.at_exit do
Redistat.buffer.flush(true)
end