Nightly with Akka 2.6 (#1799)

Nightly with Akka 2.6
akka · Jul 1, 2019 · 2c0ee15 · 2c0ee15
2 parents 977218e + d50419e
commit 2c0ee15
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 12 deletions.
diff --git a/mqtt/src/test/java/docs/javadsl/MqttFlowTest.java b/mqtt/src/test/java/docs/javadsl/MqttFlowTest.java
@@ -112,12 +112,9 @@ public void sendAnAckAfterMessageSent() throws Exception {
     // #create-flow-ack
 
     // #run-flow-ack
-    final Pair<Pair<NotUsed, CompletionStage<Done>>,
-            CompletionStage<List<MqttMessageWithAck>>>
+    final Pair<Pair<NotUsed, CompletionStage<Done>>, CompletionStage<List<MqttMessageWithAck>>>
         materialized =
-            source.viaMat(mqttFlow, Keep.both())
-                    .toMat(Sink.seq(), Keep.both())
-                    .run(materializer);
+            source.viaMat(mqttFlow, Keep.both()).toMat(Sink.seq(), Keep.both()).run(materializer);
 
     // #run-flow-ack
 
@@ -131,11 +128,10 @@ public void sendAnAckAfterMessageSent() throws Exception {
   class MqttMessageWithAckFake extends MqttMessageWithAckImpl {
     Boolean acked;
 
-    MqttMessageWithAckFake(){
+    MqttMessageWithAckFake() {
       acked = false;
     }
 
-
     @Override
     public CompletionStage<Done> messageArrivedComplete() {
       return ack();

diff --git a/project/Dependencies.scala b/project/Dependencies.scala
@@ -3,15 +3,14 @@ import Keys._
 
 object Dependencies {
 
+  val Nightly = sys.env.get("TRAVIS_EVENT_TYPE").contains("cron")
+
   val Scala211 = "2.11.12"
   val Scala212 = "2.12.7"
   val Scala213 = "2.13.0"
-  val ScalaVersions = Seq(Scala212, Scala211, Scala213)
+  val ScalaVersions = Seq(Scala212, Scala211, Scala213).filterNot(_ == Scala211 && Nightly)
 
-  val AkkaVersion = sys.env.get("AKKA_SERIES") match {
-    case Some("2.4") => sys.error("Akka 2.4 is not supported anymore")
-    case _ => "2.5.23"
-  }
+  val AkkaVersion = if (Nightly) "2.6.0-M3" else "2.5.23"
 
   val InfluxDBJavaVersion = "2.15"