Struct EgressBuilder 

pub struct EgressBuilder { /* private fields */ }

Builds an Egress incrementally and validates it on the final stage.

Implementations

impl EgressBuilder

pub fn new() -> Self

Creates a new Egress builder.

pub fn with_name(self, name: impl AsRef<str>) -> Self

Recreates this egress definition builder with the given name.

pub fn with_exchange(self, exchange: impl AsRef<str>) -> Self

Recreates this egress definition builder with the given exchange name.

pub fn with_routing_key(self, routing_key: impl AsRef<str>) -> Self

Recreates this egress definition builder with the given routing key.

pub fn with_confirmation(self, confirmation: ConfirmationLevel) -> Self

Recreates this egress definition builder with the given confirmation level.

pub fn with_force_durable(self, force_durable: bool) -> Self

Recreates this egress definition builder with the given force_durable flag.

pub fn build(self) -> Result<Egress, EgressError>

Finalizes the builder, validates its state, and, assuming valid state, returns the [Ingress].

In case the exchange name is the name of one of the known built-in RabbitMQ exchanges, some validation is applied on the given values. The built-in exchanges either require a non-empty routing key, or, on the opposite, ignore the routing key. For built-in exchanges, this method will return an error if the given routing key does not match the requirement.

Trait Implementations

impl Debug for EgressBuilder

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

Formats the value using the given formatter.