直播技术>> reactive-zeromq>> 返回
项目作者： sjednac

项目描述 ：
A minimal Akka Streams library for implementing flows with ZeroMQ sockets.
高级语言： Scala
项目地址: git://github.com/sjednac/reactive-zeromq.git
创建时间： 2016-02-29T19:43:03Z
项目社区：https://github.com/sjednac/reactive-zeromq
开源协议：Other
下载


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:

  1. sbt benchmarks/gatling-it:test