The Flow Intelligence
Operating System

Architecture

Capabilities

Every message carries business context

Intent-Aware Message Protocol (IAMP) embeds business signals directly into the message envelope — priority, slaDeadline, businessSignal, aiContext, correlationId, and causationId. Your routing layer, ops team, and ML model all see the same rich context out of the box.

// OwlMQ message envelope — business context built in
const message: OwlMQMessage = {
  payload: { orderId: 'ord_123', amount: 4999 },
  metadata: {
    priority: 'high',
    slaDeadline: Date.now() + 5000,
    businessSignal: { isVip: true },
    causationId: 'checkout.session.started'
  }
};

Routes smarter with every message

Multi-armed bandit routing (epsilon-greedy + Thompson Sampling) learns from delivery outcomes in real time. VIP customers automatically get low-latency routes. Hard rules always override AI — 40% lower average delivery latency from day one.

// Inspect the AI routing decision
const result = await client.publish('orders.created', message);

console.log(result.routingDecision);
// → { selectedRoute: 'consumer-group-vip',
//     confidence: 0.97,
//     reason: 'VIP + high priority + P99 < 5ms SLA' }

Prevents queue saturation before it happens

OwlMQ's ML model predicts queue depth 30–60 seconds ahead and applies backpressure policies automatically before consumers fall behind. Self-tunes partition counts and consumer scaling without operator intervention. 99% fewer queue saturation events in production.

Understand message relationships, not just messages

Every message carries correlationId and causationId. OwlMQ builds causal graphs automatically — complete audit trail from HTTP request to SQL query, across every service boundary. Built-in compliance for HIPAA, SOX, and FedRAMP.

// Trace any message back through its causal chain
const trace = await client.trace('msg_abc123');

trace.causalChain.forEach(msg => console.log(
  `${msg.causationId} → ${msg.id}`
));
// → http.request.checkout → order.created
// → order.created → payment.initiated
// → payment.initiated → fulfillment.queued

Detects anomalies and fixes itself in <2 seconds

Define playbooks: IF queue_depth > 10,000 for 5 min THEN scale_consumers + alert. OwlMQ executes autonomously in under 2 seconds. Six anomaly types detected out of the box. Confidence-weighted decisions: above 90% = autonomous; 60–90% = escalate to operator.

// Define a self-healing playbook
await client.playbooks.create({
  name: 'Auto-scale on queue depth spike',
  conditions: [{ metric: 'queue_depth', op: '>', threshold: 10_000 }],
  actions: ['SCALE_CONSUMERS', 'SEND_ALERT'],
  confidence: 0.90
});

Know the cost of every message, mapped to revenue

Track cost-per-message and cost-per-customer. Map message flows to NPS, churn risk, and revenue outcomes. Route VIP customers with premium SLA automatically. Reduce churn prediction time from weeks to real time.

Full causal visibility — not just metrics

SHA-256 hash-chained immutable audit log. 19 Prometheus metrics with tenant-scoped labels. Distributed tracing (OpenTelemetry) from HTTP request to SQL query. PII scrubbing before export. ClickHouse for 1-year analytics retention with sub-second query performance.

Enterprise isolation without enterprise complexity

Row-Level Security on every table. JWT RS256 with tenant context in claims. Per-tenant rate limits, plan enforcement, and audit logs — all enforced at the protocol layer. Schema-per-tenant on Enterprise. A single OwlMQ cluster serves hundreds of tenants at a fraction of the cost of separate brokers.

Developer-First

import { OwlMQ } from '@owlmq/sdk';

const client = new OwlMQ({ token: process.env.OWLMQ_TOKEN });

await client.publish('orders.created', {
  payload: {
    orderId: 'ord_123',
    amount: 4999,
    currency: 'INR'
  },
  metadata: {
    priority: 'high',
    slaDeadline: Date.now() + 5000,   // 5s SLA
    businessSignal: {
      customerId: 'cust_vip_42',
      isVip: true,
      revenueSegment: 'enterprise'
    }
  }
});
// → AI routes to low-latency consumer group automatically

Full Comparison

“We replaced Kafka in 2 days. I expected a week-long migration with schema rewrites and partition reconfiguration. OwlMQ's migration tooling handled our 47 topics automatically. The AI routing alone cut our consumer scaling events by 80%. We went from 3 Kafka ops incidents per week to zero.”

“The predictive backpressure is genuinely magic. Our payment processing queue used to hit saturation every Friday during peak load — we'd get paged at 11pm. OwlMQ's ML model predicts the spike 45 seconds out and pre-scales consumers automatically. Our support tickets dropped 60% in the first month.”

“The AI routing saved us 3 full-time engineers. We used to have a dedicated team manually tuning RabbitMQ exchange bindings as our product lines grew. With OwlMQ, business teams define routing rules in plain English and the AI handles the rest. Best infrastructure decision we've made.”

Pricing

• ✓10 queues (topics)
• ✓100,000 messages/day
• ✓7-day retention
• ✓Single region (us-east-1)
• ✓Basic CLI + REST API
• ✓Dead-letter queue
• ✓Community Discord support

• ✓25 queues
• ✓5,000,000 messages/day
• ✓30-day retention
• ✓AI routing (basic)
• ✓Multi-region read replicas
• ✓Real-time analytics dashboard
• ✓Email support (24h)
• ✓99.9% SLA

• ✓100 queues
• ✓50,000,000 messages/day
• ✓90-day retention
• ✓Full AI routing + predictions
• ✓Demand forecasting
• ✓Causal message graphs
• ✓Custom anomaly detection rules
• ✓Priority support (4h SLA)
• ✓99.95% uptime SLA
• ✓Custom domains