# File lib/stomp_server/queue.rb, line 42 def save_queue_state now=Time.now @next_save ||=now if now >= @next_save puts "Saving Queue State" if $DEBUG qinfo = {:queues => @queues, :frames => @frames} # write then rename to make sure this is atomic File.open("#{@directory}/qinfo.new", "wb") { |f| f.write Marshal.dump(qinfo)} File.rename("#{@directory}/qinfo.new","#{@directory}/qinfo") @next_save=now+checkpoint_interval end end