NAME

MangoX::Queue::Tutorial

QUICK START

Non-blocking mode using Mojo::IOLoop

1. Get a Mango collection

   
               
   
                 
                 
   my $mango = Mango->new('mongodb://localhost:27017');
   my $collection = $mango->db('foo')->collection('bar');
               
             

2. Create a MangoX::Queue

   
               
   
                 
                 
   my $queue = MangoX::Queue->new(collection => $collection);
               
             

3. Add a job to the queue

   
               
   
                 
                 
   enqueue $queue 'job_name' => sub {
       my ($job_id) = @_;
       # ...
   }
               
             

4. Consume the queue to receive jobs

   
               
   
                 
                 
   my $consumer = consume $queue sub {
       my ($job) = @_;
       # ...
   };
               
             

5. Stop consuming the queue

   
               
   
                 
                 
   release $queue $consumer;
               
             

6. Update the job status in the queue

   
               
   
                 
                 
   $job->{status} = 'Finished';
   update $queue $job => sub {
       my ($job) = @_;
       # ...
   };
               
             

7. Remove the job from the queue

   
               
   
                 
                 
   dequeue $queue $job => sub {
       # ...
   };
               
             

Blocking mode

1. Get a Mango collection

   
               
   
                 
                 
   my $mango = Mango->new('mongodb://localhost:27017');
   my $collection = $mango->db('foo')->collection('bar');
               
             

2. Create a MangoX::Queue

   
               
   
                 
                 
   my $queue = MangoX::Queue->new(collection => $collection);
               
             

3. Add a job to the queue

   
               
   
                 
                 
   my $job_id = enqueue $queue 'job_name';
               
             

4. Consume the queue to receive jobs

   
               
   
                 
                 
   while (my $job = consume $queue) {
       # ...
   };
               
             

5. Update the job status in the queue

   
               
   
                 
                 
   $job->{status} = 'Finished';
   my $job = update $queue $job;
               
             

6. Remove the job from the queue

   
               
   
                 
                 
   dequeue $queue $job;