Struct Ingress 

pub struct Ingress { /* private fields */ }

Defines an inbound path for messages being consumed from a RabbitMQ cluster.

Implementations

impl Ingress

pub fn builder() -> IngressBuilder

Creates a new IngressBuilder.

impl Ingress

pub fn name(&self) -> &str

Reports the ingress name for this definition.

pub fn exchange(&self) -> &Exchange

Returns the exchange definition as part of this ingress definition.

pub fn queue(&self) -> &Queue

Returns the queue definition as part of this ingress definition.

pub fn durable(&self) -> bool

Reports the ingress durable flag for this definition.

pub fn exclusive(&self) -> bool

Reports the ingress exclusive flag for this definition.

pub fn auto_delete(&self) -> bool

Reports the ingress auto_delete flag for this definition.

pub fn no_ack(&self) -> bool

Reports the desired no_ack value for a consumer based on this ingress definition.

This boolean value is recognized by RabbitMQ and can be a bit misleading:

• false = messages must be acknowledged manually by the client.
• true = messages are acknowledged automatically by the broker,

pub fn delivers_pending(&self) -> bool

Reports whether the messages delivered by a consumer based on this ingress definition are delivered in pending state (need to be manually finalized) or are delivered pre-finalized (pre-acknowledged on delivery).

pub fn batch_size(&self) -> NonZeroUsize

Reports the ingress batch size for this definition.

The [Subscriber] supports batch-consuming messages. After the first message of the batch is consumed, any message that arrive within the timeout will be appended to the same batch, unless this size limit is reached.

pub fn batch_timeout(&self) -> Duration

Reports the ingress batch timeout for this definition.

The [Subscriber] supports batch-consuming messages. After the first message of the batch is consumed, any message that arrive within this timeout will be appended to the same batch, unless the size limit is reached.

pub fn prefetch_count(&self) -> Option<NonZeroU16>

Reports the ingress prefetch count for this definition.

pub fn acking_behavior(&self) -> AckingBehavior

Reports the ingress acking behavior for this definition.

pub fn gibberish_behavior(&self) -> FinalizationKind

Reports the ingress gibberish behavior for this definition.

pub fn binding_keys(&self) -> &HashSet<String>

Reports the ingress binding keys for this definition.

pub fn binding_headers(&self) -> &HashMap<String, Header>

Reports the ingress binding headers for this definition.

pub fn headers_behavior(&self) -> HeadersMatchingBehavior

Reports the ingress headers behavior for this definition.

Trait Implementations

impl AsRef<Ingress> for Ingress

fn as_ref(&self) -> &Ingress

Converts this type into a shared reference of the (usually inferred) input type.

impl Clone for Ingress

fn clone(&self) -> Ingress

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Ingress

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Ingress

fn deserialize<D>(deserializer: D) -> Result<Self, D::Error>

where D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for Ingress

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Eq for Ingress

impl StructuralPartialEq for Ingress