Struct stan::SubscriptionConfig

pub struct SubscriptionConfig<'a> {
    pub queue_group: Option<&'a str>,
    pub durable_name: Option<&'a str>,
    pub start: SubscriptionStart,
    pub max_in_flight: i32,
    pub ack_wait_in_secs: i32,
}

Configuration to pass to subscription. Defaults to no queue group, no durable queue and starts from last received message.

Fields

queue_group: Option<&'a str>

Name of the queue group, see: https://docs.nats.io/nats-concepts/queue

durable_name: Option<&'a str>

Set this to keep position after reconnect, see: https://docs.nats.io/developing-with-nats-streaming/durables

start: SubscriptionStart

Position to start the subscription from

max_in_flight: i32

ack_wait_in_secs: i32

Trait Implementations

impl<'a> Debug for SubscriptionConfig<'a>

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

Formats the value using the given formatter.

impl<'a> Default for SubscriptionConfig<'a>

fn default() -> Self

Returns the “default value” for a type.