Docu updated. Preparing for automated releases.

README.md

@@ -65,5 +65,5 @@ consumer.source.map { delivery =>
 ## How to add it to your project
 The library is available both for Scala 2.11.x and 2.12.x. All you have to do is to add the dependency:
 ```scala
-"com.holidaycheck" %% "amqp-akka-streams" % "1.3.1"
+"com.holidaycheck" %% "amqp-akka-streams" % "1.4.0"
 ```

docker-compose.yml

@@ -0,0 +1,19 @@
+version: '2'
+services:
+  test:
+    image: hseeberger/scala-sbt:8u141-jdk_2.12.3_0.13.16
+    volumes:
+      - .:/source
+      - ~/.ivy2:/root/.ivy2
+    working_dir: /source
+    command: sbt clean compile test it:test
+  publish:
+      image: hseeberger/scala-sbt:8u141-jdk_2.12.3_0.13.16
+      depends_on:
+        - test
+      volumes:
+        - .:/source
+        - ~/.ivy2:/root/.ivy2
+        - ~/.sbt/gpg:/root/.sbt/gpg/
+      working_dir: /source
+      command: sbt '+ publishSigned' '+ sonatypeRelease'

src/test/scala/com/holidaycheck/streams/amqp/AmqpPublisherSpec.scala

@@ -18,28 +18,37 @@
 
 package com.holidaycheck.streams.amqp
 
+import java.util.concurrent.TimeUnit
+
 import akka.actor.ActorSystem
 import akka.util.ByteString
 import com.rabbitmq.client.{Channel, Connection, Consumer, Envelope}
 import com.rabbitmq.client.AMQP._
 import org.reactivestreams.Publisher
 import org.reactivestreams.tck.{PublisherVerification, TestEnvironment}
 import org.scalamock.scalatest.PathMockFactory
-import org.scalatest.Matchers
+import org.scalatest.{BeforeAndAfterAll, Matchers}
 import org.scalatest.testng.TestNGSuiteLike
 
-import scala.concurrent.Future
+import scala.concurrent.{Await, Future}
 import scala.concurrent.ExecutionContext.Implicits.global
+import scala.concurrent.duration.FiniteDuration
 
 
 class AmqpPublisherSpec
   extends PublisherVerification[Delivery[ByteString]](new TestEnvironment(500, true))
     with TestNGSuiteLike
     with Matchers
-    with PathMockFactory {
+    with PathMockFactory
+    with BeforeAndAfterAll {
 
   implicit val system: ActorSystem = ActorSystem()
 
+  override def afterAll(): Unit = {
+    super.afterAll()
+    Await.ready(system.terminate(), FiniteDuration(1, TimeUnit.SECONDS))
+  }
+
   def ctx(connectionArg: Connection) = new AmqpContext {
     override val configuration: AmqpConfiguration = AmqpConfiguration(
       host = "host",