OMQ::SCATTER and OMQ::GATHER
SCATTER and GATHER socket types (RFC 49) for OMQ.
Single-frame PUSH/PULL equivalent. SCATTER round-robins, GATHER fair-queues.
Usage
require "omq"
require "omq/rfc/scattergather"
gather = OMQ::GATHER.bind("tcp://127.0.0.1:5555")
scatter = OMQ::SCATTER.connect("tcp://127.0.0.1:5555")
scatter << "work item"
msg = gather.receive # => "work item"
Installation
gem "omq-rfc-scattergather"
Requires omq >= 0.12.