Consume.scala

val connect: Task[Queue[Task]] = Task
  .eval(logger.info("[queue-start] connecting"))
  .flatMap(_ => connector.connect)
  .map { q =>
    logger.info("[queue-start] connected")
    q
  }

def consumeQueue(queue: Queue[Task]): Task[Unit] =
  Task
    .eval(logger.info("[queue] receiving message"))
    .flatMap(_ => queue.read())
    .flatMap(msg => inbox.put(Received(msg)))
    .cancelable
    .restartUntil(_ => false)

def releaseQueue(queue: Queue[Task]): Task[Unit] =
  Task
    .eval(logger.info("[queue-stop] closing"))
    .flatMap(_ => queue.close())
    .map(_ => logger.info("[queue-stop] closed"))