LIFO

In some cases, it is useful to process jobs in a LIFO (Last-in, First-Out) fashion. This means that the newest jobs added to the queue will be processed before the older ones.

TypeScript

import { Queue } from 'bullmq';

const myQueue = new Queue('Paint');

// Add a job that will be processed before all others
await myQueue.add('wall', { color: 'pink' }, { lifo: true });

Python

from bullmq import Queue

queue = Queue('Paint')

# Add a job that will be processed before all others
await queue.add('wall', {'color': 'pink'}, {'lifo': True})

Elixir

# Add a job that will be processed before all others
{:ok, _job} =
  BullMQ.Queue.add("Paint", "wall", %{color: "pink"}, connection: :my_redis, lifo: true)

.NET

using BullMQ;

await using var queue = new Queue("Paint", new QueueOptions
{
    Connection = ConnectionOptions.FromString("localhost:6379"),
});

// Add a job that will be processed before all others
await queue.AddAsync("wall", new { color = "pink" }, new JobsOptions { Lifo = true });

Rust

use bullmq::Queue;

let queue = Queue::new("Paint").await?;

// Add a job that will be processed before all others
queue
    .add("wall", serde_json::json!({ "color": "pink" }))
    .lifo()
    .await?;

PHP

<?php

use BullMQ\Queue;

$queue = new Queue('Paint');

// Add a job that will be processed before all others
$queue->add('wall', ['color' => 'pink'], ['lifo' => true]);