okmq

API REST simples para entrega confiável de mensagens. Persistência, estratégias de retry, suporte a TTL e long polling em tempo real — com preço fixo que cresce com você, sem cobranças por uso medido.

Apenas HTTP. É isso.

Envie e receba mensagens usando padrões REST familiares. Sem SDKs, sem clientes especiais.

Exemplo Completo

const host = 'https://api.okmq.net'
const token = process.env.OKMQ_API_KEY

// Create queue (only needed once)
await fetch(\`${host}/queues\`, {
  method: 'POST',
  headers: { authorization: token, 'content-type': 'application/json' },
  body: JSON.stringify({ name: 'demo', auto_ack: true })
})

// consumer
const consumer = async () => {
  while (true) {
    const response = await fetch(\`${host}/queues/demo/messages\`, {
      headers: { authorization: token }
    })

    const messages = await response.json()
    console.log('Received:', messages)
  }
}

// Start consumer in background
consumer()

// producer
setInterval(async () => {
  await fetch(\`${host}/queues/demo/messages\`, {
    method: 'POST',
    headers: { authorization: token, 'content-type': 'application/json' },
    body: JSON.stringify([{
      id: \`msg-${Date.now()}\`,
      body: \`Hello at ${new Date().toISOString()}\`
    }])
  })
}, 1000)

Recursos

Tudo o que você precisa para processamento confiável de mensagens

Tópicos

Publique em tópicos para distribuição fan-out para múltiplas filas

Estratégias de Retry

Padrões de retry exponencial, linear e fixo

Polling em Tempo Real

Recuperação instantânea de mensagens com suporte a long polling

Tags de Mensagem

Filtre e organize mensagens dentro de uma única fila

Entrega Agendada

Atrase a entrega de mensagens até um horário específico

Streams

Streams de eventos persistentes com consumo baseado em offset e replay

Para fluxos de trabalho agênticos

Uma caixa de entrada durável para cada ator

Uma fila por ator, tags para endereçamento. Escalação é um reenvio que carrega a falha — então um retry não é uma repetição, é uma tentativa mais inteligente. OKMQ é a camada de caixa de entrada durável entre decisões, não um orquestrador.

Escalação com memória

Uma tarefa falha é reenviada ao próximo ator com o erro anexado. O retry sabe o que deu errado.

Locks reivindicam o trabalho

A duração do lock é o lease da reivindicação. Um ator que falha no meio da tarefa libera a mensagem para o próximo poller.

Portões de aprovação

Pause antes de qualquer coisa irreversível. O veredito humano é uma mensagem durável — conceder e rejeitar são simétricos.

Por que Escolher OKMQ?

Veja como o OKMQ se compara a outros serviços de mensageria gerenciados

Recurso	OKMQ	AWS SQS	GCP Pub/Sub
Estratégias de Retry	4 Tipos Integrados	Básico + DLQ	Exponencial Apenas
Agendamento de Mensagens	Suporte Nativo	Filas com Atraso
Filtragem de Mensagens	Baseada em Tags		Atributos
Tamanho da Mensagem	1MB	1MB	10MB
Suporte a TTL	Integrado	Apenas Retenção	Apenas Retenção
Fan-out de Tópicos	Integrado	Via SNS	Recurso Principal
Padrões de Consumo	Ambos os Modelos	Apenas Competitivo	Ambos os Modelos
Padrões nativos para agentes	Documentados	Nenhum	Nenhum
Modelo de preço	Fixo e previsível	Medido	Medido

Preço Simples e Transparente

Escolha o plano que atende às suas necessidades. Todos os planos incluem nossos recursos principais.

Pague pela capacidade reservada, não pelo uso medido. Sem surpresas na fatura no final do mês.

Grátis

$0 /mês

Perfeito para começar

Starter

$5 /mês

Perfeito para pequenos projetos

Mais Popular

Pro

$10 /mês

Perfeito para aplicações em produção

Pronto para Começar?

Envie sua primeira mensagem em minutos com apenas curl. Comece grátis, faça upgrade quando precisar escalar.

OU

Camada gratuita disponível

API HTTP simples

Configuração em menos de 5 minutos