Skip to content

Commit 4a26fa6

Browse files
author
Maxim Fedorov
committed
Final cleanup before release
1 parent b66c6c8 commit 4a26fa6

File tree

8 files changed

+11
-34
lines changed

8 files changed

+11
-34
lines changed

build.sbt

Lines changed: 4 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -6,14 +6,8 @@ enablePlugins(OssLibPlugin)
66
licenses := Seq(("Apache License, Version 2.0", url("http://www.apache.org/licenses/LICENSE-2.0")))
77
homepage := Some(new URL("https://github.com/thenewmotion/akka-rabbitmq"))
88

9-
javaVersion := "1.7"
10-
119
def akka(scalaVersion: String) = {
12-
val version = scalaVersion match {
13-
case x if x.startsWith("2.11") => "2.4.9"
14-
case x if x.startsWith("2.10") => "2.3.15"
15-
case other => throw new Exception(s"Unsupported scala version $other")
16-
}
10+
val version = "2.4.14"
1711

1812
def libs(xs: String*) = xs.map(x => "com.typesafe.akka" %% s"akka-$x" % version)
1913

@@ -23,9 +17,9 @@ def akka(scalaVersion: String) = {
2317
libraryDependencies ++= {
2418
akka(scalaVersion.value) ++
2519
Seq(
26-
"com.rabbitmq" % "amqp-client" % "3.6.5",
27-
"com.typesafe" % "config" % "1.3.0" % "test",
28-
"org.specs2" %% "specs2-mock" % "3.8.4" % "test"
20+
"com.rabbitmq" % "amqp-client" % "4.0.0",
21+
"com.typesafe" % "config" % "1.3.1" % "test",
22+
"org.specs2" %% "specs2-mock" % "3.8.6" % "test"
2923
)
3024
}
3125

project/build.properties

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1 +1 @@
1-
sbt.version=0.13.12
1+
sbt.version=0.13.13

project/plugins.sbt

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
resolvers += "TNM" at "http://nexus.thenewmotion.com/content/groups/public"
22

3-
addSbtPlugin("com.thenewmotion" % "sbt-build-seed" % "1.8.1")
3+
addSbtPlugin("com.thenewmotion" % "sbt-build-seed" % "2.1.0")
44

55
addSbtPlugin("com.typesafe.sbt" % "sbt-scalariform" % "1.3.0")
66

src/main/scala/com/thenewmotion/akka/rabbitmq/RabbitMqActor.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -37,4 +37,4 @@ sealed trait ShutdownSignal
3737
case class AmqpShutdownSignal(cause: ShutdownSignalException) extends ShutdownSignal {
3838
def appliesTo(x: AnyRef) = cause.getReference eq x
3939
}
40-
case object ParentShutdownSignal extends ShutdownSignal
40+
case object ParentShutdownSignal extends ShutdownSignal

src/test/scala-2.10/com/thenewmotion/akka/rabbitmq/examples/ActorSystemTerminator.scala

Lines changed: 0 additions & 8 deletions
This file was deleted.

src/test/scala-2.11/com/thenewmotion/akka/rabbitmq/examples/ActorSystemTerminator.scala

Lines changed: 0 additions & 9 deletions
This file was deleted.

src/test/scala/com/thenewmotion/akka/rabbitmq/examples/ConfirmsExample.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@ import scala.concurrent.duration._
1414
* successfully delivered to RabbitMQ. See https://www.rabbitmq.com/confirms.html for more information on publisher
1515
* confirms.
1616
*/
17-
object ConfirmsExample extends App with ActorSystemTerminator {
17+
object ConfirmsExample extends App {
1818

1919
/* --- Some things shared by publisher and consumer --- */
2020

@@ -100,7 +100,7 @@ object ConfirmsExample extends App with ActorSystemTerminator {
100100
/* --- Letting the app run --- */
101101

102102
Thread.sleep(7000)
103-
Await.result(terminateActorSystem(system), 1.second)
103+
Await.result(system.terminate(), 1.second)
104104

105105
System.out.println(s"Unconfirmed messages: ${unconfirmed.mkString(", ")}")
106106
}

src/test/scala/com/thenewmotion/akka/rabbitmq/examples/TutorialInComparisons.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,7 @@ import scala.concurrent.duration._
88
/**
99
* @author Yaroslav Klymko
1010
*/
11-
class TutorialInComparisons(implicit system: ActorSystem) extends ActorSystemTerminator {
11+
class TutorialInComparisons(implicit system: ActorSystem) {
1212

1313
val connection = {
1414
val factory = new ConnectionFactory()
@@ -79,6 +79,6 @@ class TutorialInComparisons(implicit system: ActorSystem) extends ActorSystemTer
7979
Await.result({
8080
system stop channelActor
8181
system stop connectionActor // will close all channels associated with this connections
82-
terminateActorSystem(system)
82+
system.terminate()
8383
}, 5.seconds)
8484
}

0 commit comments

Comments
 (0)