Contents

module StompServer
class DBMQueue < Queue

  def initialize *args
    super

    @@log = Logger.new(STDOUT)
    @@log.level = StompServer::LogHelper.get_loglevel()

    # Please don't use dbm files for storing large frames, it's problematic at best and uses large amounts of memory.
    # sdbm croaks on marshalled data that contains certain characters, so we don't use it at all
    @dbm = false
    if RUBY_PLATFORM =~/linux|bsd/
      types = ['bdb','dbm','gdbm']
    else
      types = ['bdb','gdbm']
    end
    types.each do |dbtype|
      begin
        require dbtype
        @dbm = dbtype
        @@log.info "#{@dbm} loaded"
        break
      rescue LoadError => e
      end
    end
    raise "No DBM library found. Tried bdb,dbm,gdbm" unless @dbm
    @db = Hash.new
    @queues.keys.each {|q| _open_queue(q)}
  end

  def dbmopen(dbname)
    if @dbm == 'bdb'
      BDB::Hash.new(dbname, nil, "a")
    elsif @dbm == 'dbm'
      DBM.open(dbname)
    elsif @dbm == 'gdbm'
      GDBM.open(dbname)
    end
  end


  def _open_queue(dest)
    queue_name = dest.gsub('/', '_')
    dbname = @directory + '/' + queue_name
    @db[dest] = Hash.new
    @db[dest][:dbh] = dbmopen(dbname)
    @db[dest][:dbname] = dbname
  end


  def _close_queue(dest)
    @db[dest][:dbh].close
    dbname = @db[dest][:dbname]
    File.delete(dbname) if File.exists?(dbname)
    File.delete("#{dbname}.db") if File.exists?("#{dbname}.db")
    File.delete("#{dbname}.pag") if File.exists?("#{dbname}.pag")
    File.delete("#{dbname}.dir") if File.exists?("#{dbname}.dir")
  end

  def _writeframe(dest,frame,msgid)
    @db[dest][:dbh][msgid] = Marshal::dump(frame)
  end

  def _readframe(dest,msgid)
    frame_image = @db[dest][:dbh][msgid]
    Marshal::load(frame_image)
  end

end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
stompserver_ng-1.0.6	lib/stomp_server_ng/queue/dbm_queue.rb