private def tagWriterTerminated()

in core/src/main/scala/org/apache/pekko/persistence/cassandra/journal/TagWriters.scala [460:488]

• 29 lines of code
• 6 McCabe index (conditional complexity)

  private def tagWriterTerminated(tag: String): Unit = {
    tagActors.get(tag) match {
      case Some(ref) =>
        passivatingTagActors.get(tag) match {
          case Some(buffer) =>
            tagActors = tagActors - tag
            passivatingTagActors = passivatingTagActors - tag
            if (buffer.isEmpty)
              log.debug("Tag writer {} for tag [{}] terminated after passivation.", ref, tag)
            else {
              log.debug(
                "Tag writer {} for tag [{}] terminated after passivation, but starting again " +
                "because [{}] messages buffered.",
                ref,
                tag,
                buffer.size)
              sendPassivateBuffer(tag, buffer)
            }
          case None =>
            log.warning(
              "Tag writer {} for tag [{}] terminated without passivation. Please raise an issue with debug logs.",
              ref,
              tag)
            tagActors = tagActors - tag
        }
      case None =>
        log.warning("Unknown tag writer for tag [{}] terminated. Please raise an issue with debug logs.", tag)
    }
  }