Configuration

import { ReliableQueue } from '@aplanka/reliable-queue';

const queue = new ReliableQueue({
  maxRetries: 3,
  retryDelay: 1000,
  exponentialBackoff: true,
  concurrency: 2,
  persistent: false,
  storageKey: 'my-app-queue'
});

// Linear retry delays (1s, 1s, 1s)
const linearQueue = new ReliableQueue({
  maxRetries: 3,
  retryDelay: 1000,
  exponentialBackoff: false
});

// Exponential backoff (1s, 2s, 4s, 8s)
const exponentialQueue = new ReliableQueue({
  maxRetries: 4,
  retryDelay: 1000,
  exponentialBackoff: true,
  maxRetryDelay: 10000 // Cap at 10 seconds
});

// Custom retry logic
queue.setProcessor(async (data, task) => {
  try {
    await processTask(data);
  } catch (error) {
    // Handle specific error types differently
    if (error.code === 'RATE_LIMIT') {
      // Longer delay for rate limit errors
      task.processAt = Date.now() + 60000; // 1 minute
      throw error;
    }
    throw error;
  }
});

// Process one task at a time (default)
const serialQueue = new ReliableQueue({
  concurrency: 1
});

// Process up to 5 tasks simultaneously
const parallelQueue = new ReliableQueue({
  concurrency: 5
});

// Different concurrency for different queue types
const emailQueue = new ReliableQueue({
  concurrency: 3  // Send 3 emails at once
});

const imageQueue = new ReliableQueue({
  concurrency: 1  // Process images one at a time
});

// Browser persistence with localStorage
const persistentQueue = new ReliableQueue({
  persistent: true,
  storageKey: 'user-tasks'  // Custom storage key
});

// Node.js - persistence is automatically disabled
const nodeQueue = new ReliableQueue({
  persistent: true  // Will be ignored in Node.js
});

// Check if persistence is active
if (queue.config.persistent) {
  console.log('Queue will survive page refreshes');
}

import { ReliableQueue, QueueManager } from '@aplanka/reliable-queue';

// High-throughput email queue
const emailQueue = new ReliableQueue({
  maxRetries: 5,           // Email delivery is critical
  retryDelay: 2000,        // Start with 2 second delays
  exponentialBackoff: true,
  maxRetryDelay: 300000,   // Max 5 minutes between retries
  concurrency: 10,         // Send 10 emails simultaneously
  persistent: true,
  storageKey: 'email-queue'
});

// Image processing queue
const imageQueue = new ReliableQueue({
  maxRetries: 2,           // Images can be reprocessed easily
  retryDelay: 5000,        // Longer initial delay
  exponentialBackoff: true,
  maxRetryDelay: 60000,    // Max 1 minute between retries
  concurrency: 2,          // CPU intensive, limit concurrency
  persistent: false        // Don't persist large image data
});

// Background sync queue
const syncQueue = new ReliableQueue({
  maxRetries: 10,          // Keep trying for a long time
  retryDelay: 1000,
  exponentialBackoff: true,
  maxRetryDelay: 3600000,  // Max 1 hour between retries
  concurrency: 1,          // Ensure ordered processing
  persistent: true,
  storageKey: 'sync-queue'
});