consume abstract method

Future<Consumer> consume({
  1. String consumerTag,
  2. bool noLocal = false,
  3. bool noAck = true,
  4. bool exclusive = false,
  5. bool noWait = false,
  6. Map<String, Object> arguments,
})

Create a consumer for processing queued messages and return a Future<Consumer> to the created consumer.

You may specify a consumerTag to label this consumer. If left unspecified, the server will assign a random tag to this consumer. Consumer tags are local to the current channel.

The noAck flag will notify the server whether the consumer is expected to acknowledge incoming messages or not.

If the exclusive flag is set then only this consumer has access to the queue. If the flag is set and the queue already has attached consumers, then the server will raise an error.

Implementation

Future<Consumer> consume(
    {String consumerTag,
    bool noLocal = false,
    bool noAck = true,
    bool exclusive = false,
    bool noWait = false,
    Map<String, Object> arguments});