Enum QueueCommand 

pub enum QueueCommand {
    Purge {
        queue: String,
    },
    Length {
        queue: String,
    },
    Delete {
        queue: String,
        if_empty: bool,
        if_unused: bool,
    },
    Bind {
        queue: String,
        exchange: String,
        routing_key: String,
    },
    Unbind {
        queue: String,
        exchange: String,
        routing_key: String,
    },
    Declare {
        queue: String,
        durable: bool,
        exclusive: bool,
        auto_delete: bool,
    },
}

Queue control sub-commands

Variants

Purge

Purge all messages from a queue

Fields

queue: String

Queue name to purge

Length

Get the number of messages in a queue

Fields

queue: String

Queue name to check

Delete

Delete a queue

Fields

queue: String

Queue name to delete

if_empty: bool

Only delete if queue is empty

if_unused: bool

Only delete if queue has no consumers

Bind

Bind a queue to an exchange (AMQP)

Fields

queue: String

Queue name

exchange: String

Exchange name

routing_key: String

Routing key

Unbind

Unbind a queue from an exchange (AMQP)

Fields

queue: String

Queue name

exchange: String

Exchange name

routing_key: String

Routing key

Declare

Declare a new queue

Fields

queue: String

Queue name

durable: bool

Whether the queue should survive broker restart

exclusive: bool

Whether the queue is exclusive to this connection

auto_delete: bool

Whether the queue should be auto-deleted when unused

Implementations

impl QueueCommand

pub fn queue_name(&self) -> &str

Get the queue name this command operates on

Trait Implementations

impl Clone for QueueCommand

fn clone(&self) -> QueueCommand

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for QueueCommand

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for QueueCommand

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for QueueCommand

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.