postMessages method

Future postMessages(
  1. Iterable<T> messages
)

Implementation

Future postMessages(Iterable<T> messages) async {
  var client = getClient();
  amqp.Queue queue = await (await client.channel()).queue(queueName);
  for (var m in messages) {
    queue.publish(jsonEncode(m));
  }
  await client.close();
}