blob: c3606d23ac54da18bdeee427c95641e00224af2b (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
|
package akka.instrumentation
import org.scalatest.WordSpec
import org.scalatest.matchers.{ShouldMatchers, MustMatchers}
import akka.actor.{Actor, Props, ActorSystem}
import kamon.metric.Metrics._
import scala.collection.JavaConverters._
class ActorInstrumentationSpec extends WordSpec with MustMatchers with ShouldMatchers {
val system = ActorSystem()
import system._
val echoRef = actorOf(Props(new EchoActor), "Echo-Actor")
val meterForEchoActor = "meter-for-akka://default/user/Echo-Actor"
val totalMessages = 1000
"an instrumented Actor" should {
"send a message and record a metric on the Metrics Registry with the number of sent messages" in {
(1 to totalMessages).foreach {x:Int =>
echoRef ! s"Message ${x}"
}
//to ensure that all messages was received
Thread.sleep(1000)
val messages = registry.getMeters.asScala.get(meterForEchoActor).get.getCount
messages should equal(totalMessages)
}
}
}
class EchoActor extends Actor {
def receive = {
case msg ⇒ sender ! msg
}
}
|