WorkMQ

WorkMQ é uma biblioteca robusta para gerenciamento de filas de trabalho usando Redis. Ela permite criar, gerenciar e processar trabalhos assíncronos de forma confiável e escalável.

Características

• Filas de trabalho robustas e escaláveis
• Processamento assíncrono com retentativas automáticas
• Suporte para trabalhos programados e recorrentes
• Dependências entre trabalhos
• Priorização de trabalhos
• Monitoramento de progresso
• Sandboxing para isolamento de processos

Instalação

npm install workmq
# ou
yarn add workmq

Uso Básico

import { Queue, Worker } from 'workmq';

// Criar uma fila
const fila = new Queue('minha-fila');

// Adicionar um trabalho à fila
await fila.add('enviar-email', { 
  destinatario: '[email protected]', 
  assunto: 'Olá!' 
});

// Processar trabalhos da fila
const worker = new Worker('minha-fila', async (trabalho) => {
  // Aqui está a lógica para processar o trabalho
  console.log(`Enviando email para ${trabalho.data.destinatario}`);
  
  // Retorna um resultado quando concluído
  return { enviado: true };
});

Documentação

A documentação completa da API está disponível na pasta docs/ deste projeto. Abra o arquivo docs/index.html no seu navegador para acessar a documentação detalhada.

Problemas Conhecidos

Alguns testes automatizados estão falhando atualmente. Esses problemas estão documentados no arquivo KNOWN_ISSUES.md e serão abordados em uma futura atualização.

Licença

Este projeto está licenciado sob a Licença MIT - veja o arquivo LICENSE para detalhes.