getClient method

Implementation

amqp.Client getClient() {
  amqp.ConnectionSettings settings = amqp.ConnectionSettings(host: config.getRequired<String>('amqp.host'), port: config.getRequired<int>('amqp.port'));
  return amqp.Client(settings: settings);
}