Struct amiquip::ConsumerOptions
source ·
[−]pub struct ConsumerOptions {
pub no_local: bool,
pub no_ack: bool,
pub exclusive: bool,
pub arguments: FieldTable,
}
Expand description
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
Returns the “default value” for a type. Read more
Auto Trait Implementations
impl RefUnwindSafe for ConsumerOptions
impl Send for ConsumerOptions
impl Sync for ConsumerOptions
impl Unpin for ConsumerOptions
impl UnwindSafe for ConsumerOptions
Blanket Implementations
Mutably borrows from an owned value. Read more