postMessage method

Future postMessage(
  1. T message
)

Implementation

Future postMessage(T message) async {
  amqp.ConnectionSettings settings = amqp.ConnectionSettings(
      host: config.getRequired<String>('amqp.host'),
      port: config.getRequired<int>('amqp.port')
  );
  amqp.Client client = amqp.Client(settings: settings);
  amqp.Channel channel = await client.channel();
  amqp.Queue queue = await channel.queue(queueName);
  queue.publish(jsonEncode(message));
  await client.close();
}