Struct AmqpAddress 

pub struct AmqpAddress { /* private fields */ }

A subscription descriptor for an AMQP 1.0 address.

Implements SubscriptionSource, so it can sit inline in the #[subscriber(..)] decorator:

use ruststream_amqp::AmqpAddress;

let source = AmqpAddress::queue("orders").credit(64);

Implementations

impl AmqpAddress

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

An anycast address: competing consumers, each message delivered to one of them.

Examples

use ruststream_amqp::AmqpAddress;
let source = AmqpAddress::queue("orders");

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

A multicast address: fan-out, each message delivered to every subscriber.

Examples

use ruststream_amqp::AmqpAddress;
let source = AmqpAddress::topic("events");

pub fn raw(address: impl Into<String>) -> Self

A verbatim address, for deployments with their own addressing convention ("/queues/orders" on RabbitMQ 4.x, a fully qualified queue on Artemis).

Examples

use ruststream_amqp::AmqpAddress;
let source = AmqpAddress::raw("/queues/orders");

pub fn credit(self, credit: u32) -> Self

Sets the protocol-level credit (prefetch): how many unsettled deliveries the broker may have in flight to this subscription. Defaults to DEFAULT_CREDIT.

pub fn settle(self, settle: Settle) -> Self

Sets the delivery guarantee. Defaults to Settle::AtLeastOnce.

pub fn address(&self) -> &str

The address string sent to the broker.

Trait Implementations

impl Clone for AmqpAddress

fn clone(&self) -> AmqpAddress

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AmqpAddress

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

Formats the value using the given formatter.

impl Eq for AmqpAddress

impl PartialEq for AmqpAddress

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for AmqpAddress

impl SubscriptionSource<ConnectedAmqpBroker> for AmqpAddress

type Subscriber = AmqpSubscriber

The subscriber type this source opens.

fn name(&self) -> &str

The name (subject / channel) this subscription binds to.

async fn subscribe( self, connected: &ConnectedAmqpBroker, ) -> Result<AmqpSubscriber, AmqpError>

Opens the subscription against the connected broker. Called once at startup.