Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- trait LatencyRecorderActor extends Actor with StrictLogging {
- val actorName: String = this.getClass.getSimpleName
- abstract override def receive: Receive = {
- case recordableMessage: RecordableMessage =>
- Monitor.record("time-in-mailbox", actorName, recordableMessage.messageName,
- recordableMessage.dispatchTime)
- val start = System.currentTimeMillis()
- super.receive(recordableMessage)
- Monitor.record("processing-time", actorName, recordableMessage.messageName, start)
- case message => super.receive(message)
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement