Akka/Scala example source code file (HakkerStatusTest.scala)

This example Akka source code file (HakkerStatusTest.scala) is included in my "Source Code Warehouse" project. The intent of this project is to help you more easily find Akka and Scala source code examples by using tags.

All credit for the original source code belongs to akka.io; I'm just trying to make examples easier to find. (For my Scala work, see my Scala examples and tutorials.)

Akka tags/keywords

actorsystem, akka, array, concurrent, dininghakkerservice, duration, filter, identify, illegalstateexception, inject, test, testhakker, testing, testkit, testprobe, time

The HakkerStatusTest.scala Akka example source code

package akka.sample.osgi.test

import akka.actor.{ Identify => _, _ }
import akka.sample.osgi.api._
import akka.sample.osgi.test.TestOptions._
import akka.testkit.TestProbe
import javax.inject.Inject
import org.junit.runner.RunWith
import org.junit.{ Before, Test }
import org.ops4j.pax.exam.junit.{ Configuration, JUnit4TestRunner }
import org.ops4j.pax.exam.util.Filter
import org.ops4j.pax.exam.{ Option => PaxOption }
import org.scalatest.junit.{AssertionsForJUnit, JUnitSuite}
import org.scalatest.Matchers
import scala.concurrent.duration._
import org.apache.karaf.tooling.exam.options.LogLevelOption

/**
 * This is a ScalaTest based integration test. Pax-Exam, which is responsible for loading the test class into
 * the OSGi environment and executing it, currently does not support ScalaTest directly. However, ScalaTest
 * provides a JUnit-compatible runner, so the test is defined to use that runner. Pax-Exam can then invoke
 * it as a normal JUnit test. Because Pax Exam is using the JUnitRunner and not one of the ScalaTest traits such
 * as FunSuite, the test should be defined using the JUnit @Test annotation.
 *
 * This is a simple test demonstrating in-container integration testing.
 *
 * One thing to note is that we only depend on the API bundle, not the implementation in core. The implementation
 * is injected into the test at runtime via an OSGi service lookup performed by Pax Exam.
 *
 * TODO attempt to use the Akka test probe
 */
@RunWith(classOf[JUnit4TestRunner])
class HakkerStatusTest extends JUnitSuite with Matchers with AssertionsForJUnit {

  @Inject @Filter(timeout = 30000)
  var actorSystem: ActorSystem = _

  @Inject @Filter(timeout = 30000)
  var service: DiningHakkersService = _

  var testProbe: TestProbe = _

  @Configuration
  def config: Array[PaxOption] = Array[PaxOption](
    karafOptionsWithTestBundles(),
    featureDiningHakkers() //, debugOptions(level = LogLevelOption.LogLevel.DEBUG)
    )

  // Junit @Before and @After can be used as well

  @Before
  def setupAkkaTestkit() {
    testProbe = new TestProbe(actorSystem)
  }

  @Test
  def verifyObtainingAHakkerViaTheTheDiningHakkersService() {

    val name = "TestHakker"
    val hakker = Option(service.getHakker(name, 2))
      .getOrElse(throw new IllegalStateException("No Hakker was created via DiningHakkerService"))

    // takes some time for the first message to get through
    testProbe.within(10.seconds) {
      testProbe.send(hakker, Identify)
      val Identification(fromHakker, busyWith) = testProbe.expectMsgType[Identification]

      println("---------------> %s is busy with %s.".format(fromHakker, busyWith))
      fromHakker should be("TestHakker")
      busyWith should not be (null)
    }

  }

  @Test
  def verifyHakkerTracker() {

    val name = "TestHakker"
    val hakker = service.getHakker(name, 3)
    val tracker = service.getTracker()
    tracker ! TrackHakker(hakker)
    testProbe.within(10.seconds) {
      testProbe.awaitAssert {
        testProbe.within(1.second) {
          tracker.tell(GetEatingCount(name), testProbe.ref)
          val reply = testProbe.expectMsgType[EatingCount]
          reply.hakkerName should be(name)
          reply.count should be > (0)
        }
      }
    }
  }

}