Module: OMQ::QoS::RoundRobinExt

Defined in:

lib/omq/qos/routing_ext.rb

Overview

Prepended onto Routing::RoundRobin. Branches by QoS level:

0 — no-op, defer entirely to base.
1 — existing {PendingStore} path. Disconnect drains entries
  back into the send queue (failover).
2 — {PeerRegistry} path. Each outgoing message carries an
  {Async::Promise} (via {OMQ::QoS#take_enqueue_promise}); the
  registry pins it to the peer's {Protocol::ZMTP::PeerInfo}
  and a connection-drop leaves entries in place for replay
  on reconnect (or dead-letter after the timeout).