cgi-bin/LJ/PersistentQueue.pm

   1 package LJ::PersistentQueue;
   2
   3 use strict;
   4 use warnings;
   5
   6 use LJ::Data::Queue::Persistent;
   7
   8 sub new {
   9     my ($class, %opts) = @_;
  10
  11     my $dbh = delete $opts{dbh} || LJ::get_db_writer();
  12
  13     return LJ::Data::Queue::Persistent->new(
  14                                         table => 'persistent_queue',
  15                                         cache => 0,
  16                                         dbh   => $dbh,
  17                                         %opts,
  18                                         );
  19 }
  20
  21
  22
  23 package LJ;
  24
  25 sub queue {
  26     my ($id, $size) = @_;
  27
  28     return LJ::PersistentQueue->new(id => $id, max_size => $size);
  29 }
  30
  31
  32 1;