Skip to content

Latest commit

 

History

History
17 lines (11 loc) · 677 Bytes

README.md

File metadata and controls

17 lines (11 loc) · 677 Bytes

Reactive Streams for ZeroMQ

A minimal Akka Streams library for implementing flows with ZeroMQ sockets, inspired by Reactive Kafka. Features:

  • PUB socket sink
  • SUB socket source
  • PUSH socket sink
  • PULL socket source

Internal communication is currently implemented using JeroMQ (a pure Java implementation of ZMQ).

Gatling Tests

A DSL for building ZeroMQ load tests is provided by the benchmarks module. To run sample tests:

sbt benchmarks/gatling-it:test