okmq

okmq proporciona a los agentes de IA una cola de mensajes simple. Permite a los clientes publicar y consumir mensajes a través de MCP, facilitando la creación de flujos de trabajo ligeros y prototipos.

Documentación

API REST simple para entrega confiable de mensajes. Persistencia, estrategias de reintento, soporte de TTL y polling de larga duración en tiempo real — con precios planos que crecen contigo, no facturas por uso.

Solo HTTP. Eso es todo.

Envía y recibe mensajes usando patrones REST familiares. Sin SDKs, sin clientes especiales.

Ejemplo 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)

Características

Todo lo que necesitas para el procesamiento confiable de mensajes

Topics

Publica en topics para distribución fan-out a múltiples colas

Estrategias de Reintento

Patrones de reintento exponencial, lineal y fijo

Polling en Tiempo Real

Recuperación instantánea de mensajes con soporte de polling de larga duración

Etiquetas de Mensajes

Filtra y organiza mensajes dentro de una sola cola

Entrega Programada

Retrasa la entrega de mensajes hasta un momento específico

Streams

Flujos de eventos persistentes con consumo basado en offset y reproducción

Para flujos de trabajo agénticos

Una bandeja de entrada duradera para cada actor

Una cola por actor, etiquetas para direccionamiento. La escalación es un reenvío que lleva el fallo — así que un reintento no es una repetición, es un intento más inteligente. OKMQ es la capa de bandeja de entrada duradera entre decisiones, no un orquestador.

Escalación con memoria

Una tarea fallida se reenvía al siguiente actor con el error adjunto. El reintento sabe qué salió mal.

Los bloqueos reclaman el trabajo

La duración del bloqueo es el arrendamiento del reclamo. Un actor que falla a mitad de tarea libera el mensaje al siguiente poller.

Puertas de aprobación

Pausa antes de cualquier cosa irreversible. El veredicto humano es un mensaje duradero — conceder y rechazar son simétricos.

¿Por Qué Elegir OKMQ?

Mira cómo OKMQ se compara con otros servicios de mensajería gestionados

CaracterísticaOKMQAWS SQSGCP Pub/Sub
Estrategias de Reintento4 Tipos IntegradosBásico + DLQSolo Exponencial
Programación de MensajesSoporte NativoColas de Retraso
Filtrado de MensajesBasado en EtiquetasAtributos
Tamaño de Mensaje1MB1MB10MB
Soporte TTLIntegradoSolo RetenciónSolo Retención
Fan-out de TopicsIntegradoVía SNSCaracterística Principal
Patrones de ConsumoAmbos ModelosSolo CompetitivoAmbos Modelos
Patrones nativos para agentesDocumentadosNingunoNinguno
Modelo de preciosPlano y predeciblePor usoPor uso

Precios Simples y Transparentes

Elige el plan que se ajuste a tus necesidades. Todos los planes incluyen nuestras características principales.

Paga por capacidad reservada, no por uso medido. Sin facturas sorpresa a fin de mes.

Gratis

$0 /mes

Perfecto para comenzar

Starter

$5 /mes

Perfecto para proyectos pequeños

Más Popular

Pro

$10 /mes

Perfecto para aplicaciones de producción

¿Listo para Empezar?

Envía tu primer mensaje en minutos con solo curl. Comienza gratis, actualiza cuando necesites escalar.

O

Nivel gratuito disponible

API HTTP simple

Configuración en menos de 5 minutos