def initialize(directory='.stompserver', delete_empty=true)
@stompid = StompServer::StompId.new
@delete_empty = delete_empty
@directory = directory
Dir.mkdir(@directory) unless File.directory?(@directory)
if File.exists?("#{@directory}/qinfo")
qinfo = Hash.new
File.open("#{@directory}/qinfo", "rb") { |f| qinfo = Marshal.load(f.read)}
@queues = qinfo[:queues]
@frames = qinfo[:frames]
else
@queues = Hash.new
@frames = Hash.new
end
@queues.keys.each do |dest|
puts "Queue #{dest} size=#{@queues[dest][:size]} enqueued=#{@queues[dest][:enqueued]} dequeued=#{@queues[dest][:dequeued]}" if $DEBUG
end
puts "Queue initialized in #{@directory}"
end