react rabbit:用于AMQP协议的Reactive Streams驱动程序。 由RabbitMQ库提供支持 源码

React性流:AMQP 适用于AMQP协议的驱动程序。 由库提供支持。 在Maven Central中可用于Scala 2.11和2.12: libraryDependencies += "io.scalac" %% "reactive-rabbit" % "1.1.4" 例子 Akka流-2.4.12 import akka . actor . ActorSystem import akka . stream . ActorMaterializer import akka . stream . scaladsl .{ Sink , Source } import io . scalac . amqp . Connection // streaming invoices to Accounting Department val connection = Connection ()