Struct RabbitExchange 

pub struct RabbitExchange { /* private fields */ }

Describes the exchange side of a RabbitQueue binding.

Like every descriptor in this crate it only records the EXPECTED topology; nothing is declared unless the broker was built with declare_topology(true).

Examples

use ruststream_lapin::RabbitExchange;

let events = RabbitExchange::topic("events").durable(true);
assert_eq!(events.name(), "events");

Implementations

impl RabbitExchange

pub fn direct(name: impl Into<String>) -> Self

A direct exchange: routes on an exact routing-key match.

pub fn topic(name: impl Into<String>) -> Self

A topic exchange: routes on dot-separated routing-key patterns (order.*).

pub fn fanout(name: impl Into<String>) -> Self

A fanout exchange: routes every message to every bound queue.

pub fn headers(name: impl Into<String>) -> Self

A headers exchange: routes on header attributes instead of the routing key.

pub fn custom(name: impl Into<String>, kind: impl Into<String>) -> Self

An exchange of a plugin-provided type, for example "x-delayed-message".

pub fn consistent_hash(name: impl Into<String>) -> Self

A consistent-hash exchange (the x-consistent-hash type from the rabbitmq_consistent_hash_exchange plugin): distributes messages across the queues bound to it by hashing the routing key, so partition-like fan-out is a server-side concern rather than a client one.

Each queue binds with a routing key that is its integer weight ("1", "2", …); the broker splits the hash space proportionally. Requires the plugin to be enabled on the broker, so it lives behind the plugin-consistent-hash feature.

Examples

use ruststream_lapin::{RabbitExchange, RabbitQueue};

let hashed = RabbitExchange::consistent_hash("orders-by-key");
// Bind a queue with its weight as the routing key:
let shard = RabbitQueue::new("shard-a").bind(hashed, "1");

pub fn durable(self, durable: bool) -> Self

Whether the exchange survives a broker restart. Defaults to true.

pub fn auto_delete(self, auto_delete: bool) -> Self

Whether the exchange is deleted when its last binding is removed. Defaults to false.

pub fn name(&self) -> &str

The exchange name.

Trait Implementations

impl Clone for RabbitExchange

fn clone(&self) -> RabbitExchange

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RabbitExchange

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

Formats the value using the given formatter.

impl Eq for RabbitExchange

impl PartialEq for RabbitExchange

fn eq(&self, other: &RabbitExchange) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for RabbitExchange