Full Capability Breakdown

Every feature your team needs

Eight foundational capabilities that redefine what a message broker can be.

🧠

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.

vs. RabbitMQ / Kafka / SQS — every competitor treats messages as opaque byte arrays. OwlMQ is the only broker that embeds intent natively in the protocol.

// 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.

vs. Kafka static round-robin / RabbitMQ manual bindings / SQS no routing — OwlMQ is the only broker with a learning routing engine that optimizes for business outcomes.

// 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.

vs. every other broker — competitors are reactive (they tell you a queue is full after it already is). OwlMQ is predictive. No competitor offers ML-based queue depth forecasting.

🕸️

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.

vs. RabbitMQ / Kafka / SQS — no competitor tracks message causality. OwlMQ makes it a protocol primitive.

// 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.

vs. RabbitMQ / Kafka requiring 30–60 min manual MTTR — OwlMQ detects and resolves anomalies before your on-call engineer gets paged. No competitor offers self-healing playbooks.

// 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.

vs. RabbitMQ / Kafka / SQS — every other broker has no concept of customers or revenue. They see messages; OwlMQ sees business outcomes. Category-defining capability unavailable anywhere else.

📊

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.

vs. Kafka needing Confluent Control Center / RabbitMQ requiring third-party monitoring — OwlMQ ships a complete observability stack with no additional tooling required.

🏢

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.

vs. Kafka complex ACL management / RabbitMQ limited vhosts — OwlMQ delivers enterprise-grade isolation as a first-class feature, not a bolt-on.

Ready to try every feature?

All features are available on a free account. No credit card, no sales call required.

Get Started Free Read the Docs