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;