Struct amiquip::ConsumerOptions

pub struct ConsumerOptions {
    pub no_local: bool,
    pub no_ack: bool,
    pub exclusive: bool,
    pub arguments: FieldTable,
}

Options passed to the server when starting a consumer.

The default implementation sets all boolean fields to false and has an empty set of arguments.

Example

The arguments field can be used to set a consumer priority:

let mut arguments = FieldTable::new();
arguments.insert("x-priority".to_string(), AmqpValue::ShortInt(10));
let options = ConsumerOptions {
    arguments,
    ..ConsumerOptions::default()
};

Fields

no_local: bool

If true, the server will not send this consumer messages that were published by the consumer's connection.

no_ack: bool

If true, the server assumes all delivered messages are acknowledged, and the client should not acknowledge messages. If using this option, be aware of unbounded memory growth concerns.

exclusive: bool

If true, requires that this consumer is the only one attached to the queue. If other consumers are active, the server will close the channel.

arguments: FieldTable

Extra arguments; these are optional in general, but may be needed for some plugins or server-specific features.

Trait Implementations

impl Clone for ConsumerOptions

fn clone(&self) -> ConsumerOptions

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ConsumerOptions

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for ConsumerOptions

fn default() -> ConsumerOptions

Returns the "default value" for a type.