finishQueuesIsolate method

Future finishQueuesIsolate()

Implementation

Future finishQueuesIsolate() async {
  if (amqpClient != null) {
    for (var consumer in amqpConsumers) {
      await consumer.cancel();
    }
    await amqpClient!.close();
  }
}