AkkaTelnetSample.scala

class Telnet extends Actor with ActorLogging {
  override def receive : Receive = {
    case Connected(remote, _) =>
      log.info(s"Incoming connection from: $remote")
      val handler = context.actorOf(Props[SimplisticHandler])
      sender() ! Register(handler)
  }
}

class SimplisticHandler extends Actor with ActorLogging {
  def receive = {
    case Received(data) =>
      log.info("I have received something, answer is on the way")
      sender() ! Write("Hello, ".map(_.toByte) ++ data)
    case PeerClosed     =>
      log.info("Connection closed by peer")
      context stop self
  }
}