Skip to content

Commit

Permalink
Upgrade Alpakka version and hoping for stability
Browse files Browse the repository at this point in the history
  • Loading branch information
ledoyen committed Jul 22, 2020
1 parent f138c10 commit d0043d1
Show file tree
Hide file tree
Showing 2 changed files with 9 additions and 8 deletions.
12 changes: 6 additions & 6 deletions src/it/alpakka/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -19,14 +19,14 @@
<rabbitmq-mock.version>@rabbitmq-mock.version@</rabbitmq-mock.version>

<scala.version>2.13</scala.version>
<scala-library.version>${scala.version}.0</scala-library.version>
<akka.version>2.5.25</akka.version>
<alpakka.version>1.1.1</alpakka.version>
<junit.version>5.5.2</junit.version>
<scalatest.version>3.0.8</scalatest.version>
<scala-library.version>${scala.version}.3</scala-library.version>
<akka.version>2.5.31</akka.version>
<alpakka.version>2.0.1</alpakka.version>
<junit.version>5.6.2</junit.version>
<scalatest.version>3.2.0</scalatest.version>

<maven-surefire-plugin.version>2.22.2</maven-surefire-plugin.version>
<scala-maven-plugin.version>4.2.0</scala-maven-plugin.version>
<scala-maven-plugin.version>4.4.0</scala-maven-plugin.version>
<scalatest-maven-plugin.version>2.0.0</scalatest-maven-plugin.version>
</properties>
<dependencies>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -7,14 +7,15 @@ import akka.testkit.{ImplicitSender, TestKit, TestProbe}
import com.github.fridujo.rabbitmq.mock.{MockChannel, MockConnectionFactory}
import com.rabbitmq.client.AMQP.BasicProperties
import com.rabbitmq.client.{AMQP, Channel, Connection, ConnectionFactory, DefaultConsumer, Envelope}
import org.scalatest.FunSuiteLike
import org.scalatest.funsuite.AnyFunSuiteLike

import scala.collection.JavaConverters._
import scala.concurrent.duration._

/**
* @author mdiasribeiro
*/
class TestSuite extends TestKit(ActorSystem("TestSuite")) with ImplicitSender with FunSuiteLike {
class TestSuite extends TestKit(ActorSystem("TestSuite")) with ImplicitSender with AnyFunSuiteLike {

def bindActorToQueue(channel: Channel, receiver: ActorRef, queueName: String, consumerTag: String = "myConsumerTag"): Unit = {
channel.basicConsume(queueName, true, consumerTag, new DefaultConsumer(channel) {
Expand Down

0 comments on commit d0043d1

Please sign in to comment.