ConsumerQueueActor.scala

class ConsumeQueueActor(connector: QueueConnector[Future]) 
  extends Actor with ActorLogging {
   
  import context.dispatcher  
    
  private var currentQueue: Option[Queue[Future]] = None  
  
  // ...
  
  override def receive: Receive = {
    case queue: Queue[Future] =>
      if (currentQueue.isEmpty) {
        log.info("[queue-start] connected")
        currentQueue = Some(queue)
      }
      log.info("[queue] receiving message")
      queue
        .read()
        .pipeTo(self) // forward message to self
        .andThen { case Success(_) => self ! queue } // receive next message

    case msg: String =>
      context.parent ! Received(msg)

    case Failure(e) =>
      log.info(s"[queue] failure: ${e.getMessage}")
      throw e
  }
}