pulsar 6.7.2

Rust client for Apache Pulsar
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31

use std::time::Duration;

use crate::{
    consumer::{data::DeadLetterPolicy, options::ConsumerOptions},
    message::proto::command_subscribe::SubType,
};

/// the complete configuration of a consumer
#[derive(Debug, Clone, Default)]
pub struct ConsumerConfig {
    /// subscription name
    pub(crate) subscription: String,
    /// subscription type
    ///
    /// default: Shared
    pub(crate) sub_type: SubType,
    /// maximum size for batched messages
    ///
    /// default: 1000
    pub(crate) batch_size: Option<u32>,
    /// name of the consumer
    pub(crate) consumer_name: Option<String>,
    /// numerical id of the consumer
    pub(crate) consumer_id: Option<u64>,
    /// time after which unacked messages will be sent again
    pub(crate) unacked_message_redelivery_delay: Option<Duration>,
    /// consumer options
    pub(crate) options: ConsumerOptions,
    /// dead letter policy
    pub(crate) dead_letter_policy: Option<DeadLetterPolicy>,
}