Skip to content

Commit

Permalink
Update README to Akka Streams 1.0 RC-4
Browse files Browse the repository at this point in the history
  • Loading branch information
mkiedys committed Jul 9, 2015
1 parent 0140b48 commit 1f0bf34
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions README.md
Expand Up @@ -7,16 +7,16 @@ Reactive Streams: AMQP

Available at Maven Central for Scala 2.10 and 2.11:

libraryDependencies += "io.scalac" %% "reactive-rabbit" % "1.0.0"
libraryDependencies += "io.scalac" %% "reactive-rabbit" % "1.0.1"

Example
----

#### Akka Streams - 1.0-RC2
#### Akka Streams - 1.0-RC4

```Scala
import akka.actor.ActorSystem
import akka.stream.ActorFlowMaterializer
import akka.stream.ActorMaterializer
import akka.stream.scaladsl.{Sink, Source}
import io.scalac.amqp.Connection

Expand All @@ -28,7 +28,7 @@ val exchange = connection.publish(exchange = "accounting_department",
routingKey = "invoices")

implicit val system = ActorSystem()
implicit val materializer = ActorFlowMaterializer()
implicit val mat = ActorMaterializer()

Source(queue).map(_.message).to(Sink(exchange)).run()
```

0 comments on commit 1f0bf34

Please sign in to comment.