ConsumeQueueActor.scala

class ConsumeQueueActor(connector: QueueConnector[Future]) 
  extends Actor with ActorLogging {
  
  import context.dispatcher

  private var currentQueue: Option[Queue[Future]] = None

  override def preStart(): Unit = // ...

  override def postStop(): Unit = {
    log.info("[queue-stop] stopping queue actor")
    currentQueue.foreach { queue =>
      log.info("[queue-stop] closing")
      Await.result(queue.close(), 1.minute)
      log.info("[queue-stop] closed")
    }
  }
    
  // ...
}