pub struct AmqpQueueOptions {
pub name: String,
pub is_recv: bool,
pub reliable: bool,
pub broadcast: bool,
pub reconnect_millis: u64,
pub prefetch: u16,
pub persistent: bool,
}
Expand description
The queue options.
Fields§
§name: String
The queue name that is used to map a AMQP queue (unicast) or an exchange (broadcast).
The pattern is QUEUE_NAME_PATTERN
.
is_recv: bool
true
for the receiver and false
for the sender.
reliable: bool
Reliable by selecting the confirm channel (for publish).
broadcast: bool
true
for broadcast and false
for unicast.
reconnect_millis: u64
Time in milliseconds from disconnection to reconnection.
Default or zero value is 1000
.
prefetch: u16
The QoS of the receiver queue.
Note: this value MUST be a positive value.
persistent: bool
Use persistent delivery mode.
Trait Implementations§
Source§impl Clone for AmqpQueueOptions
impl Clone for AmqpQueueOptions
Source§fn clone(&self) -> AmqpQueueOptions
fn clone(&self) -> AmqpQueueOptions
Returns a copy of the value. Read more
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source
. Read moreAuto Trait Implementations§
impl Freeze for AmqpQueueOptions
impl RefUnwindSafe for AmqpQueueOptions
impl Send for AmqpQueueOptions
impl Sync for AmqpQueueOptions
impl Unpin for AmqpQueueOptions
impl UnwindSafe for AmqpQueueOptions
Blanket Implementations§
Source§impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
Source§impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more