private def handleReceivedEvent()

in pekko-sample-distributed-workers-scala/src/main/scala/worker/WorkResultConsumerActor.scala [19:32]

14 lines of code
6 McCabe index (conditional complexity)


  private def handleReceivedEvent(context: ActorContext[PublishedEvent], event: PublishedEvent): Unit = {
    val actualEvent = event.event
    event.event match {
      case WorkInProgressReset =>
        context.log.info(s"Received published event [${actualEvent.getClass.getCanonicalName}]: {}", event)
      case WorkCompleted(workId) =>
        context.log.info(s"Received published event [${actualEvent.getClass.getCanonicalName}]: workId {}", workId)
      case WorkStarted(workId) =>
        context.log.info(s"Received published event [${actualEvent.getClass.getCanonicalName}]: workId {}", workId)
      case WorkAccepted(workId) =>
        context.log.info(s"Received published event [${actualEvent.getClass.getCanonicalName}]: workId {}", workId)
      case _ => context.log.warn("Message not supported")
    }
  }